com.duoec.graphql.core.subscribe

类 SubscriptionGraphqlEndpoint

java.lang.Object

com.duoec.graphql.core.subscribe.SubscriptionGraphqlEndpoint

@Component
public class SubscriptionGraphqlEndpoint
extends Object

GraphQL Subscription功能入口

作者:

xuwenzhen

构造器概要

构造器

构造器和说明
SubscriptionGraphqlEndpoint()

方法概要

限定符和类型	方法和说明
void	onClose(javax.websocket.Session session, javax.websocket.CloseReason closeReason) 连接关闭调用的方法
void	onError(javax.websocket.Session session, Throwable e)
void	onMessage(String graphqlQuery, javax.websocket.Session session) 收到客户端消息后调用的方法
void	onOpen(javax.websocket.Session session, javax.websocket.EndpointConfig config) 连接建立成功调用的方法
static void	sendMessage(javax.websocket.Session session, String message) 实现服务器主动推送

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

SubscriptionGraphqlEndpoint

public SubscriptionGraphqlEndpoint()

方法详细资料

onOpen

public void onOpen(javax.websocket.Session session,
                   javax.websocket.EndpointConfig config)

连接建立成功调用的方法

onClose

public void onClose(javax.websocket.Session session,
                    javax.websocket.CloseReason closeReason)

连接关闭调用的方法

onMessage

public void onMessage(String graphqlQuery,
                      javax.websocket.Session session)

收到客户端消息后调用的方法

参数:

graphqlQuery - 客户端发送过来的消息

session - 会话

onError

public void onError(javax.websocket.Session session,
                    Throwable e)

参数:

session - 会话

e - 错误信息

sendMessage

public static void sendMessage(javax.websocket.Session session,
                               String message)
                        throws IOException

实现服务器主动推送

抛出:

IOException