Class ConnectionTransport

    • Field Detail

      • logger

        protected final Logger logger
        Logger for this class.
      • numIoThreads

        private int numIoThreads
        Number of I/O threads.
      • numMessageThreads

        private int numMessageThreads
        Number of message threads.
    • Constructor Detail

      • ConnectionTransport

        public ConnectionTransport()
        Creates a new connection transport.
      • ConnectionTransport

        public ConnectionTransport​(int ioThreads)
        Creates a new connection transport.
        Parameters:
        ioThreads - number of threads used for I/O in the event loop group
      • ConnectionTransport

        public ConnectionTransport​(int ioThreads,
                                   int messageThreads)
        Creates a new connection transport.
        Parameters:
        ioThreads - number of threads used for I/O in the event loop group
        messageThreads - number of threads for LDAP message handling in the event loop group
    • Method Detail

      • getSocketChannelType

        protected Class<? extends io.netty.channel.Channel> getSocketChannelType()
        Returns the socket channel type used with the event loop group.
        Returns:
        socket channel type
      • createEventLoopGroup

        protected io.netty.channel.EventLoopGroup createEventLoopGroup​(String name,
                                                                       int numThreads)
        Returns a new event loop group with the supplied name and number of threads.
        Parameters:
        name - of the event loop group
        numThreads - number of worker threads
        Returns:
        new event loop group
      • create

        public Connection create​(ConnectionConfig cc)
        Description copied from interface: Transport
        Create a connection object. Implementations should not open a TCP socket in this method.
        Specified by:
        create in interface Transport
        Parameters:
        cc - connection configuration
        Returns:
        connection