public class Nio2Connector extends Nio2Service implements IoConnector
Modifier and Type | Class and Description |
---|---|
protected class |
Nio2Connector.ConnectionCompletionHandler |
static class |
Nio2Connector.DefaultIoConnectFuture |
AbstractCloseable.State
CONFIGURABLE_OPTIONS, disposing, sessions
closeFuture, futureLock, state
log
DEFAULT_REUSE_ADDRESS
Constructor and Description |
---|
Nio2Connector(FactoryManager manager,
IoHandler handler,
java.nio.channels.AsynchronousChannelGroup group) |
Modifier and Type | Method and Description |
---|---|
IoConnectFuture |
connect(java.net.SocketAddress address,
AttributeRepository context,
java.net.SocketAddress localAddress) |
protected Nio2CompletionHandler<java.lang.Void,java.lang.Object> |
createConnectionCompletionHandler(IoConnectFuture future,
java.nio.channels.AsynchronousSocketChannel socket,
AttributeRepository context,
FactoryManager manager,
IoHandler handler) |
protected Nio2Session |
createSession(FactoryManager manager,
IoHandler handler,
java.nio.channels.AsynchronousSocketChannel socket) |
protected java.nio.channels.AsynchronousSocketChannel |
openAsynchronousSocketChannel(java.net.SocketAddress address,
java.nio.channels.AsynchronousChannelGroup group) |
dispose, getChannelGroup, getFactoryManager, getInnerCloseable, getIoHandler, getIoServiceEventListener, getManagedSessions, sessionClosed, setIoServiceEventListener, setOption, setSocketOptions, unmapSession
doCloseGracefully, doCloseImmediately
addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, preClose, removeCloseFutureListener
debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getManagedSessions
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
getIoServiceEventListener, setIoServiceEventListener
public Nio2Connector(FactoryManager manager, IoHandler handler, java.nio.channels.AsynchronousChannelGroup group)
public IoConnectFuture connect(java.net.SocketAddress address, AttributeRepository context, java.net.SocketAddress localAddress)
connect
in interface IoConnector
address
- The target address to connect tocontext
- An optional "context" to be attached to the established session if successfully
connectedlocalAddress
- The local address to use - if null
an automatic ephemeral port and bind address is
usedfuture
representing the connection requestprotected java.nio.channels.AsynchronousSocketChannel openAsynchronousSocketChannel(java.net.SocketAddress address, java.nio.channels.AsynchronousChannelGroup group) throws java.io.IOException
java.io.IOException
protected Nio2CompletionHandler<java.lang.Void,java.lang.Object> createConnectionCompletionHandler(IoConnectFuture future, java.nio.channels.AsynchronousSocketChannel socket, AttributeRepository context, FactoryManager manager, IoHandler handler)
protected Nio2Session createSession(FactoryManager manager, IoHandler handler, java.nio.channels.AsynchronousSocketChannel socket) throws java.lang.Throwable
java.lang.Throwable