Package org.ldaptive.transport.netty

Class NioConnectionTransport

java.lang.Object
org.ldaptive.transport.netty.ConnectionTransport
org.ldaptive.transport.netty.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.

  • Constructor Details

    • 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 Details

    • getSocketChannelType

      protected 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(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