Package graphql.kickstart.spring.webflux.apollo

Class ReactiveApolloSubscriptionProtocolFactory

java.lang.Object
graphql.kickstart.execution.subscriptions.SubscriptionProtocolFactory
graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionProtocolFactory
graphql.kickstart.spring.webflux.apollo.ReactiveApolloSubscriptionProtocolFactory
All Implemented Interfaces:
ReactiveSubscriptionsProtocolFactory
public class ReactiveApolloSubscriptionProtocolFactory extends graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionProtocolFactory implements ReactiveSubscriptionsProtocolFactory

  • Field Summary

    Fields inherited from class graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionProtocolFactory

    KEEP_ALIVE_INTERVAL

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactiveApolloSubscriptionProtocolFactory(graphql.kickstart.execution.GraphQLObjectMapper objectMapper, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLInvoker graphQLInvoker)
     
    ReactiveApolloSubscriptionProtocolFactory(graphql.kickstart.execution.GraphQLObjectMapper objectMapper, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLInvoker graphQLInvoker, Duration keepAliveInterval)
     
    ReactiveApolloSubscriptionProtocolFactory(graphql.kickstart.execution.GraphQLObjectMapper objectMapper, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLInvoker graphQLInvoker, Collection<graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionConnectionListener> connectionListeners)
     
    ReactiveApolloSubscriptionProtocolFactory(graphql.kickstart.execution.GraphQLObjectMapper objectMapper, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLInvoker graphQLInvoker, Collection<graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionConnectionListener> connectionListeners, Duration keepAliveInterval)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    graphql.kickstart.execution.subscriptions.SubscriptionSession
    createSession(org.springframework.web.reactive.socket.WebSocketSession session)
     

    Methods inherited from class graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionProtocolFactory

    createConsumer, getObjectMapper, shutdown

    Methods inherited from class graphql.kickstart.execution.subscriptions.SubscriptionProtocolFactory

    getProtocol

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface graphql.kickstart.spring.webflux.ReactiveSubscriptionsProtocolFactory

    createConsumer

  • Constructor Details

    • ReactiveApolloSubscriptionProtocolFactory

      public ReactiveApolloSubscriptionProtocolFactory(graphql.kickstart.execution.GraphQLObjectMapper objectMapper, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLInvoker graphQLInvoker)

    • ReactiveApolloSubscriptionProtocolFactory

      public ReactiveApolloSubscriptionProtocolFactory(graphql.kickstart.execution.GraphQLObjectMapper objectMapper, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLInvoker graphQLInvoker, Duration keepAliveInterval)

    • ReactiveApolloSubscriptionProtocolFactory

      public ReactiveApolloSubscriptionProtocolFactory(graphql.kickstart.execution.GraphQLObjectMapper objectMapper, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLInvoker graphQLInvoker, Collection<graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionConnectionListener> connectionListeners)

    • ReactiveApolloSubscriptionProtocolFactory

      public ReactiveApolloSubscriptionProtocolFactory(graphql.kickstart.execution.GraphQLObjectMapper objectMapper, graphql.kickstart.execution.subscriptions.GraphQLSubscriptionInvocationInputFactory invocationInputFactory, graphql.kickstart.execution.GraphQLInvoker graphQLInvoker, Collection<graphql.kickstart.execution.subscriptions.apollo.ApolloSubscriptionConnectionListener> connectionListeners, Duration keepAliveInterval)

  • Method Details

    • createSession

      public graphql.kickstart.execution.subscriptions.SubscriptionSession createSession(org.springframework.web.reactive.socket.WebSocketSession session)
      Specified by:
      createSession in interface ReactiveSubscriptionsProtocolFactory