Package org.apache.nifi.processors.standard.ssh.netty

Class StandardNettyIoConnector

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.netty.NettyIoService

org.apache.sshd.netty.NettyIoConnector

org.apache.nifi.processors.standard.ssh.netty.StandardNettyIoConnector

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, org.apache.sshd.common.Closeable, org.apache.sshd.common.io.IoConnector, org.apache.sshd.common.io.IoService, org.apache.sshd.common.io.IoServiceEventListenerManager

public class StandardNettyIoConnector
extends org.apache.sshd.netty.NettyIoConnector

Standard extension of Netty IO Connector supporting Proxy Configuration

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	StandardNettyIoConnector.StandardChannelInitializer

Nested classes/interfaces inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

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

Field Summary

Fields

Modifier and Type	Field	Description
private final io.netty.channel.EventLoopGroup	eventLoopGroup
private final org.apache.sshd.common.FactoryManager	factoryManager
private final ProxyConfiguration	proxyConfiguration
private final Duration	socketTimeout

Fields inherited from class org.apache.sshd.netty.NettyIoService

channelGroup, CONNECT_FUTURE_KEY, factory, handler, sessions, sessionSeq

Fields inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

closeFuture, futureLock, state

Fields inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

log

Fields inherited from interface org.apache.sshd.common.io.IoService

DEFAULT_REUSE_ADDRESS

Constructor Summary

Constructors

Constructor	Description
StandardNettyIoConnector(org.apache.sshd.netty.NettyIoServiceFactory factory, org.apache.sshd.common.io.IoHandler handler, io.netty.channel.EventLoopGroup eventLoopGroup, ProxyConfiguration proxyConfiguration, Duration socketTimeout, org.apache.sshd.common.FactoryManager factoryManager)

Method Summary

Modifier and Type	Method	Description
org.apache.sshd.common.io.IoConnectFuture	connect(SocketAddress address, org.apache.sshd.common.AttributeRepository context, SocketAddress localAddress)
private io.netty.handler.proxy.ProxyHandler	getProxyHandler()

Methods inherited from class org.apache.sshd.netty.NettyIoService

doCloseImmediately, getIoServiceEventListener, getManagedSessions, mapSession, registerChannel, setIoServiceEventListener

Methods inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

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

Methods inherited from class org.apache.sshd.common.util.logging.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 java.lang.Object

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

Methods inherited from interface org.apache.sshd.common.Closeable

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

Methods inherited from interface org.apache.sshd.common.io.IoService

getManagedSessions

Methods inherited from interface org.apache.sshd.common.io.IoServiceEventListenerManager

getIoServiceEventListener, setIoServiceEventListener

Field Details

eventLoopGroup

private final io.netty.channel.EventLoopGroup eventLoopGroup

proxyConfiguration

private final ProxyConfiguration proxyConfiguration

socketTimeout

private final Duration socketTimeout

factoryManager

private final org.apache.sshd.common.FactoryManager factoryManager

Constructor Details

StandardNettyIoConnector

public StandardNettyIoConnector(org.apache.sshd.netty.NettyIoServiceFactory factory,
 org.apache.sshd.common.io.IoHandler handler,
 io.netty.channel.EventLoopGroup eventLoopGroup,
 ProxyConfiguration proxyConfiguration,
 Duration socketTimeout,
 org.apache.sshd.common.FactoryManager factoryManager)

Method Details

connect

public org.apache.sshd.common.io.IoConnectFuture connect(SocketAddress address,
 org.apache.sshd.common.AttributeRepository context,
 SocketAddress localAddress)

Specified by:

connect in interface org.apache.sshd.common.io.IoConnector

Overrides:

connect in class org.apache.sshd.netty.NettyIoConnector

getProxyHandler

private io.netty.handler.proxy.ProxyHandler getProxyHandler()