Class ReactorFactory


  • public class ReactorFactory
    extends java.lang.Object
    Factory class which provide single instance of Reactors or ResponseWorker within single loading scope.
    • Constructor Detail

      • ReactorFactory

        public ReactorFactory()
    • Method Detail

      • getReactor

        public static Reactor getReactor​(ManagerProvider provider,
                                         ReactorType type)
                                  throws ClientConnectionException
        Provides instance of Reactor based on ManagerProvider availability and type provided.
        Parameters:
        provider - Provides ability to get SSL context.
        type - ReactorType which will be created.
        Returns:
        NioReactor reactor when provider is null or SSLReactor.
        Throws:
        ClientConnectionException - when unexpected type value is provided or issue with constucting selector.
      • getWorker

        public static ResponseWorker getWorker​(int parallelism)
        Parameters:
        parallelism - the parallelism level using for event processing.
        Returns:
        Single instance of ResponseWorker.
      • getWorker

        public static ResponseWorker getWorker​(int parallelism,
                                               int eventTimeoutInHours)
        Parameters:
        parallelism - the parallelism level using for event processing.
        eventTimeoutInHours - the timeout after which the events are purged from the queue.
        Returns:
        Single instance of ResponseWorker.