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

Class Netty4IOContext

java.lang.Object

org.apache.qpid.protonj2.client.transport.netty4.Netty4IOContext

All Implemented Interfaces:

IOContext

public final class Netty4IOContext
extends Object
implements IOContext

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	Netty4IOContext.NettyIOScheduler

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Scheduler	ioScheduler()
TcpTransport	newTransport()
void	shutdown()	Shutdown the event loop synchronously with a grace period for work that might be in-bound at the time of termination.
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 Details

Netty4IOContext

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

Method Details

shutdown

public void shutdown()

Description copied from interface: IOContext

Shutdown the event loop synchronously with a grace period for work that might be in-bound at the time of termination. This is not safe to call from inside the event loop as it blocks until the shutdown has completed.

Specified by:

shutdown in interface IOContext

shutdownAsync

public void shutdownAsync()

Description copied from interface: IOContext

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.

Specified by:

shutdownAsync in interface IOContext

ioScheduler

public Scheduler ioScheduler()

Specified by:

ioScheduler in interface IOContext

Returns:

the single threaded IO work scheduler for this IOContext

newTransport

public TcpTransport newTransport()

Specified by:

newTransport in interface IOContext

Returns:

a new Transport instance that is tied to this IOContext