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,
AsynchronousChannelGroup group) |
Modifier and Type | Method and Description |
---|---|
IoConnectFuture |
connect(SocketAddress address) |
protected Nio2CompletionHandler<Void,Object> |
createConnectionCompletionHandler(IoConnectFuture future,
AsynchronousSocketChannel socket,
FactoryManager manager,
IoHandler handler) |
protected Nio2Session |
createSession(FactoryManager manager,
IoHandler handler,
AsynchronousSocketChannel socket) |
protected AsynchronousSocketChannel |
openAsynchronousSocketChannel(SocketAddress address,
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, AsynchronousChannelGroup group)
public IoConnectFuture connect(SocketAddress address)
connect
in interface IoConnector
protected AsynchronousSocketChannel openAsynchronousSocketChannel(SocketAddress address, AsynchronousChannelGroup group) throws IOException
IOException
protected Nio2CompletionHandler<Void,Object> createConnectionCompletionHandler(IoConnectFuture future, AsynchronousSocketChannel socket, FactoryManager manager, IoHandler handler)
protected Nio2Session createSession(FactoryManager manager, IoHandler handler, AsynchronousSocketChannel socket) throws Throwable
Throwable
Copyright © 2008–2019 The Apache Software Foundation. All rights reserved.