Class NioConnectionTransport

  • All Implemented Interfaces:
    Transport

    public class NioConnectionTransport
    extends ConnectionTransport
    Creates netty connections using an NioEventLoopGroup. The event loop group is shutdown when the connection is closed.
    Author:
    Middleware Services
    • Constructor Detail

      • NioConnectionTransport

        public NioConnectionTransport()
        Creates a new nio connection transport.
      • NioConnectionTransport

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

        public NioConnectionTransport​(int ioThreads,
                                      int messageThreads)
        Creates a new nio 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 java.lang.Class<? extends io.netty.channel.Channel> getSocketChannelType()
        Description copied from class: ConnectionTransport
        Returns the socket channel type used with the event loop group.
        Overrides:
        getSocketChannelType in class ConnectionTransport
        Returns:
        socket channel type
      • createEventLoopGroup

        protected io.netty.channel.EventLoopGroup createEventLoopGroup​(java.lang.String name,
                                                                       int numThreads)
        Description copied from class: ConnectionTransport
        Returns a new event loop group with the supplied name and number of threads.
        Overrides:
        createEventLoopGroup in class ConnectionTransport
        Parameters:
        name - of the event loop group
        numThreads - number of worker threads
        Returns:
        new event loop group