| Modifier and Type | Class and Description |
|---|---|
| protected class |
| Modifier and Type | Field and Description |
|---|---|
| private final Nio2ServiceFactory |
| Access | Constructor and Description |
|---|---|
| public | Nio2Connector(Nio2ServiceFactory nio2ServiceFactory, PropertyResolver propertyResolver, IoHandler handler, AsynchronousChannelGroup group, ExecutorService resumeTasks)
|
| Modifier and Type | Method and Description |
|---|---|
| public IoConnectFuture | connect(SocketAddress
The target address to connect to address, AttributeRepository An optional "context" to be attached to the established session if successfully
connected context, SocketAddress The local address to use - if localAddress)null an automatic ephemeral port and bind address is
usedImplements org.
|
| protected Nio2CompletionHandler | createConnectionCompletionHandler(IoConnectFuture future, AsynchronousSocketChannel socket, AttributeRepository context, PropertyResolver propertyResolver, IoHandler handler)
|
| protected Nio2Session | createSession(PropertyResolver propertyResolver, IoHandler handler, AsynchronousSocketChannel socket)
|
| protected AsynchronousSocketChannel |
| nio2ServiceFactory | back to summary |
|---|---|
| private final Nio2ServiceFactory nio2ServiceFactory | |
| Nio2Connector | back to summary |
|---|---|
| public Nio2Connector(Nio2ServiceFactory nio2ServiceFactory, PropertyResolver propertyResolver, IoHandler handler, AsynchronousChannelGroup group, ExecutorService resumeTasks) | |
| connect | back to summary |
|---|---|
| public IoConnectFuture connect(SocketAddress address, AttributeRepository context, SocketAddress localAddress) Implements org.
| |
| createConnectionCompletionHandler | back to summary |
|---|---|
| protected Nio2CompletionHandler | |
| createSession | back to summary |
|---|---|
| protected Nio2Session createSession(PropertyResolver propertyResolver, IoHandler handler, AsynchronousSocketChannel socket) throws Throwable | |
| openAsynchronousSocketChannel | back to summary |
|---|---|
| protected AsynchronousSocketChannel openAsynchronousSocketChannel(SocketAddress address, AsynchronousChannelGroup group) throws IOException | |
| Modifier and Type | Field and Description |
|---|---|
| protected final AttributeRepository | |
| protected final IoConnectFuture | |
| protected final IoHandler | |
| protected final PropertyResolver | |
| protected final AsynchronousSocketChannel |
| Access | Constructor and Description |
|---|---|
| protected | ConnectionCompletionHandler(IoConnectFuture future, AsynchronousSocketChannel socket, AttributeRepository context, PropertyResolver propertyResolver, IoHandler handler)
|
| Modifier and Type | Method and Description |
|---|---|
| protected void | onCompleted(Void result, Object attachment)
Implements abstract org.
|
| protected void | onFailed(Throwable exc, Object attachment)
Implements abstract org.
|
| context | back to summary |
|---|---|
| protected final AttributeRepository context | |
| future | back to summary |
|---|---|
| protected final IoConnectFuture future | |
| handler | back to summary |
|---|---|
| protected final IoHandler handler | |
| propertyResolver | back to summary |
|---|---|
| protected final PropertyResolver propertyResolver | |
| socket | back to summary |
|---|---|
| protected final AsynchronousSocketChannel socket | |
| ConnectionCompletionHandler | back to summary |
|---|---|
| protected ConnectionCompletionHandler(IoConnectFuture future, AsynchronousSocketChannel socket, AttributeRepository context, PropertyResolver propertyResolver, IoHandler handler) | |
| onCompleted | back to summary |
|---|---|
| protected void onCompleted(Void result, Object attachment) Implements abstract org.
| |
| onFailed | back to summary |
|---|---|
| protected void onFailed(Throwable exc, Object attachment) Implements abstract org.
| |