Class GraphQLWebsocketServlet

    • Constructor Summary

      Constructors 
      Constructor Description
      GraphQLWebsocketServlet​(graphql.kickstart.execution.GraphQLInvoker graphQLInvoker, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLObjectMapper graphQLObjectMapper)  
      GraphQLWebsocketServlet​(graphql.kickstart.execution.GraphQLInvoker graphQLInvoker, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLObjectMapper graphQLObjectMapper, java.util.Collection<graphql.kickstart.execution.subscriptions.SubscriptionConnectionListener> connectionListeners)  
      GraphQLWebsocketServlet​(GraphQLConfiguration configuration)  
      GraphQLWebsocketServlet​(GraphQLConfiguration configuration, java.util.Collection<graphql.kickstart.execution.subscriptions.SubscriptionConnectionListener> connectionListeners)  
      GraphQLWebsocketServlet​(java.util.List<graphql.kickstart.execution.subscriptions.SubscriptionProtocolFactory> subscriptionProtocolFactory, graphql.kickstart.execution.subscriptions.SubscriptionProtocolFactory fallbackSubscriptionProtocolFactory)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void beginShutDown()
      Stops accepting connections and closes all existing connections
      int getSessionCount()  
      int getSubscriptionCount()  
      boolean isShutDown()  
      void modifyHandshake​(javax.websocket.server.ServerEndpointConfig sec, javax.websocket.server.HandshakeRequest request, javax.websocket.HandshakeResponse response)  
      void onClose​(javax.websocket.Session session, javax.websocket.CloseReason closeReason)  
      void onError​(javax.websocket.Session session, java.lang.Throwable thr)  
      void onOpen​(javax.websocket.Session session, javax.websocket.EndpointConfig endpointConfig)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • GraphQLWebsocketServlet

        public GraphQLWebsocketServlet​(GraphQLConfiguration configuration,
                                       java.util.Collection<graphql.kickstart.execution.subscriptions.SubscriptionConnectionListener> connectionListeners)
      • GraphQLWebsocketServlet

        public GraphQLWebsocketServlet​(graphql.kickstart.execution.GraphQLInvoker graphQLInvoker,
                                       graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory,
                                       graphql.kickstart.execution.GraphQLObjectMapper graphQLObjectMapper)
      • GraphQLWebsocketServlet

        public GraphQLWebsocketServlet​(graphql.kickstart.execution.GraphQLInvoker graphQLInvoker,
                                       graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory,
                                       graphql.kickstart.execution.GraphQLObjectMapper graphQLObjectMapper,
                                       java.util.Collection<graphql.kickstart.execution.subscriptions.SubscriptionConnectionListener> connectionListeners)
      • GraphQLWebsocketServlet

        public GraphQLWebsocketServlet​(java.util.List<graphql.kickstart.execution.subscriptions.SubscriptionProtocolFactory> subscriptionProtocolFactory,
                                       graphql.kickstart.execution.subscriptions.SubscriptionProtocolFactory fallbackSubscriptionProtocolFactory)
    • Method Detail

      • onOpen

        public void onOpen​(javax.websocket.Session session,
                           javax.websocket.EndpointConfig endpointConfig)
        Specified by:
        onOpen in class javax.websocket.Endpoint
      • onClose

        public void onClose​(javax.websocket.Session session,
                            javax.websocket.CloseReason closeReason)
        Overrides:
        onClose in class javax.websocket.Endpoint
      • onError

        public void onError​(javax.websocket.Session session,
                            java.lang.Throwable thr)
        Overrides:
        onError in class javax.websocket.Endpoint
      • modifyHandshake

        public void modifyHandshake​(javax.websocket.server.ServerEndpointConfig sec,
                                    javax.websocket.server.HandshakeRequest request,
                                    javax.websocket.HandshakeResponse response)
      • beginShutDown

        public void beginShutDown()
        Stops accepting connections and closes all existing connections
      • isShutDown

        public boolean isShutDown()
        Returns:
        true when shutdown is complete
      • getSessionCount

        public int getSessionCount()
      • getSubscriptionCount

        public int getSubscriptionCount()