Class Nio2Connector

java.lang.Object

org.apache.sshd.common.util.logging.AbstractLoggingBean

org.apache.sshd.common.util.closeable.IoBaseCloseable

org.apache.sshd.common.util.closeable.AbstractCloseable

org.apache.sshd.common.util.closeable.AbstractInnerCloseable

org.apache.sshd.common.io.nio2.Nio2Service

org.apache.sshd.common.io.nio2.Nio2Connector

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, Closeable, IoConnector, IoService, IoServiceEventListenerManager

public class Nio2Connector
extends Nio2Service
implements IoConnector

TODO Add javadoc

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	Nio2Connector.ConnectionCompletionHandler

Nested classes/interfaces inherited from class AbstractCloseable

AbstractCloseable.State

Field Summary

Fields

Modifier and Type	Field	Description
private final Nio2ServiceFactory	nio2ServiceFactory

Fields inherited from class Nio2Service

CONFIGURABLE_OPTIONS, disposing, propertyResolver, sessions

Fields inherited from class AbstractCloseable

closeFuture, futureLock, state

Fields inherited from class AbstractLoggingBean

log

Fields inherited from interface IoService

DEFAULT_REUSE_ADDRESS

Constructor Summary

Constructors

Constructor	Description
Nio2Connector(Nio2ServiceFactory nio2ServiceFactory, PropertyResolver propertyResolver, IoHandler handler, AsynchronousChannelGroup group, ExecutorService resumeTasks)

Method Summary

Modifier and Type	Method	Description
IoConnectFuture	connect(SocketAddress address, AttributeRepository context, SocketAddress localAddress)
protected Nio2CompletionHandler<Void,Object>	createConnectionCompletionHandler(IoConnectFuture future, AsynchronousSocketChannel socket, AttributeRepository context, PropertyResolver propertyResolver, IoHandler handler)
protected Nio2Session	createSession(PropertyResolver propertyResolver, IoHandler handler, AsynchronousSocketChannel socket)
protected AsynchronousSocketChannel	openAsynchronousSocketChannel(SocketAddress address, AsynchronousChannelGroup group)

Methods inherited from class Nio2Service

dispose, getChannelGroup, getExecutorService, getInnerCloseable, getIoHandler, getIoServiceEventListener, getManagedSessions, mapSession, sessionClosed, setIoServiceEventListener, setOption, setSocketOptions, unmapSession

Methods inherited from class AbstractInnerCloseable

doCloseGracefully, doCloseImmediately

Methods inherited from class AbstractCloseable

addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, preClose, removeCloseFutureListener

Methods inherited from class AbstractLoggingBean

debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Closeable

addCloseFutureListener, close, close, isClosed, isClosing, isOpen, removeCloseFutureListener

Methods inherited from interface IoService

getManagedSessions

Methods inherited from interface IoServiceEventListenerManager

getIoServiceEventListener, setIoServiceEventListener

Field Details

nio2ServiceFactory

private final Nio2ServiceFactory nio2ServiceFactory

Constructor Details

Nio2Connector

public Nio2Connector(Nio2ServiceFactory nio2ServiceFactory,
 PropertyResolver propertyResolver,
 IoHandler handler,
 AsynchronousChannelGroup group,
 ExecutorService resumeTasks)

Method Details

connect

public IoConnectFuture connect(SocketAddress address,
 AttributeRepository context,
 SocketAddress localAddress)

Specified by:

connect in interface IoConnector

Parameters:

address - The target address to connect to

context - An optional "context" to be attached to the established session if successfully connected

localAddress - The local address to use - if null an automatic ephemeral port and bind address is used

Returns:

The future representing the connection request

openAsynchronousSocketChannel

protected AsynchronousSocketChannel openAsynchronousSocketChannel(SocketAddress address,
 AsynchronousChannelGroup group)
                                                           throws IOException

Throws:

IOException

createConnectionCompletionHandler

protected Nio2CompletionHandler<Void,Object> createConnectionCompletionHandler(IoConnectFuture future,
 AsynchronousSocketChannel socket,
 AttributeRepository context,
 PropertyResolver propertyResolver,
 IoHandler handler)

createSession

protected Nio2Session createSession(PropertyResolver propertyResolver,
 IoHandler handler,
 AsynchronousSocketChannel socket)
                             throws Throwable

Throws:

Throwable