Package org.apache.qpid.protonj2.client.transport

Class NettyIOContext

java.lang.Object

org.apache.qpid.protonj2.client.transport.NettyIOContext

public final class NettyIOContext
extends Object

Builder of Transport instances that will validate the build options and produce a correctly configured transport based on the options set.

Constructor Summary

Constructors

Constructor	Description
NettyIOContext(TransportOptions options, SslOptions ssl, String ioThreadName)

Method Summary

Modifier and Type	Method	Description
io.netty.channel.EventLoopGroup	eventLoop()
TcpTransport	newTransport()
void	shutdown()
void	shutdownAsync()	Shutdown the event loop asynchronously with a grace period for work that might be in-bound at the time of termination.

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyIOContext

public NettyIOContext(TransportOptions options,
                      SslOptions ssl,
                      String ioThreadName)

Method Detail

shutdown

public void shutdown()

shutdownAsync

public void shutdownAsync()

Shutdown the event loop asynchronously with a grace period for work that might be in-bound at the time of termination. This is safe to call from inside the event loop where the standard blocking shutdown API is not.

eventLoop

public io.netty.channel.EventLoopGroup eventLoop()

newTransport

public TcpTransport newTransport()