public class Nio2Connector extends Nio2Service implements IoConnector
Modifier and Type | Class and Description |
---|---|
static class |
Nio2Connector.DefaultIoConnectFuture |
AbstractCloseable.State
CONFIGURABLE_OPTIONS, disposing, sessions
closeFuture, lock, state
log
DEFAULT_REUSE_ADDRESS
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
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) |
protected Nio2CompletionHandler<java.lang.Void,java.lang.Object> |
createConnectionCompletionHandler(IoConnectFuture future,
java.nio.channels.AsynchronousSocketChannel socket,
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, getManagedSessions, sessionClosed, setOption, setSocketOptions, unmapSession
doCloseGracefully, doCloseImmediately
addCloseFutureListener, builder, close, isClosed, isClosing, preClose, removeCloseFutureListener
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getManagedSessions
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
public Nio2Connector(FactoryManager manager, IoHandler handler, java.nio.channels.AsynchronousChannelGroup group)
public IoConnectFuture connect(java.net.SocketAddress address)
connect
in interface IoConnector
protected 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, FactoryManager manager, IoHandler handler)
protected Nio2Session createSession(FactoryManager manager, IoHandler handler, java.nio.channels.AsynchronousSocketChannel socket) throws java.lang.Throwable
java.lang.Throwable