AbstractConnectionService

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.session.helpers.AbstractConnectionService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, PortForwardingEventListenerManager, PortForwardingEventListenerManagerHolder, PropertyResolver, Service, ConnectionService, SessionContextHolder, SessionHeartbeatController, SessionHolder<Session>, UnknownChannelReferenceHandlerManager

Direct Known Subclasses:

ClientConnectionService, ServerConnectionService
```
public abstract class AbstractConnectionService
extends AbstractInnerCloseable
implements ConnectionService
```
Base implementation of ConnectionService.

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable
  AbstractCloseable.State
- Nested classes/interfaces inherited from interface org.apache.sshd.common.session.SessionHeartbeatController
  SessionHeartbeatController.HeartbeatType

Field Summary

Fields
Modifier and Type	Field and Description
`private java.util.concurrent.atomic.AtomicReference<AgentForwardSupport>`	`agentForwardHolder`
`private java.util.concurrent.atomic.AtomicBoolean`	`allowMoreSessions`
`protected java.util.Map<java.lang.Integer,Channel>`	`channels` Map of channels keyed by the identifier
`static int`	`DEFAULT_MAX_CHANNELS` Default value for `MAX_CONCURRENT_CHANNELS_PROP` is none specified
`static java.lang.String`	`DEFAULT_SESSION_IGNORE_HEARTBEAT_STRING` Used in `SSH_MSH_IGNORE` messages for the keep-alive mechanism
`private java.util.concurrent.atomic.AtomicReference<ForwardingFilter>`	`forwarderHolder`
`private java.util.concurrent.ScheduledFuture<?>`	`heartBeat`
`protected java.util.concurrent.atomic.AtomicLong`	`heartbeatCount`
`private PortForwardingEventListener`	`listenerProxy`
`private java.util.Collection<PortForwardingEventListener>`	`listeners`
`private java.util.Collection<PortForwardingEventListenerManager>`	`managersHolder`
`static java.lang.String`	`MAX_CONCURRENT_CHANNELS_PROP` Property that can be used to configure max.
`protected java.util.concurrent.atomic.AtomicInteger`	`nextChannelId` Next channel identifier
`private java.util.Map<java.lang.String,java.lang.Object>`	`properties`
`static java.util.function.IntUnaryOperator`	`RESPONSE_BUFFER_GROWTH_FACTOR` Default growth factor function used to resize response buffers
`private AbstractSession`	`sessionInstance`
`private UnknownChannelReferenceHandler`	`unknownChannelReferenceHandler`
`private java.util.concurrent.atomic.AtomicReference<X11ForwardSupport>`	`x11ForwardHolder`

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.Closeable
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT

Fields inherited from interface org.apache.sshd.common.session.SessionHeartbeatController
DEFAULT_CONNECTION_HEARTBEAT_INTERVAL, SESSION_HEARTBEAT_INTERVAL, SESSION_HEARTBEAT_TYPE

Fields inherited from interface org.apache.sshd.common.PropertyResolver
EMPTY

Constructor Summary

Constructors
Modifier Constructor and Description

protected AbstractConnectionService(AbstractSession session)

Constructors
Modifier	Constructor and Description
`protected`	`AbstractConnectionService(AbstractSession session)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addPortForwardingEventListener(PortForwardingEventListener listener)` Add a port forwarding listener
`boolean`	`addPortForwardingEventListenerManager(PortForwardingEventListenerManager manager)`
`void`	`channelClose(Buffer buffer)` Close a channel due to a close packet received
`void`	`channelData(Buffer buffer)` Process incoming data on a channel
`void`	`channelEof(Buffer buffer)` Process end of file on a channel
`void`	`channelExtendedData(Buffer buffer)` Process incoming extended data on a channel
`void`	`channelFailure(Buffer buffer)` Process a failure on a channel
`protected void`	`channelOpen(Buffer buffer)`
`void`	`channelOpenConfirmation(Buffer buffer)`
`void`	`channelOpenFailure(Buffer buffer)`
`void`	`channelRequest(Buffer buffer)` Service a request on a channel
`void`	`channelSuccess(Buffer buffer)` Process a success on a channel
`void`	`channelWindowAdjust(Buffer buffer)` Process a window adjust packet on a channel
`protected AgentForwardSupport`	`createAgentForwardSupport(Session session)`
`protected ForwardingFilter`	`createForwardingFilter(Session session)`
`protected X11ForwardSupport`	`createX11ForwardSupport(Session session)`
`protected void`	`futureDone(IoWriteFuture future)`
`AgentForwardSupport`	`getAgentForwardSupport()`
`protected Channel`	`getChannel(byte cmd, Buffer buffer)` Retrieve the channel designated by the given packet
`protected Channel`	`getChannel(byte cmd, int recipient, Buffer buffer)`
`java.util.Collection<Channel>`	`getChannels()`
`ForwardingFilter`	`getForwardingFilter()` Retrieve the forwarder instance
`protected Closeable`	`getInnerCloseable()`
`protected int`	`getNextChannelId()`
`PortForwardingEventListener`	`getPortForwardingEventListenerProxy()`
`java.util.Map<java.lang.String,java.lang.Object>`	`getProperties()` A map of properties that can be used to configure the SSH server or client.
`java.util.Collection<PortForwardingEventListenerManager>`	`getRegisteredManagers()`
`AbstractSession`	`getSession()`
`UnknownChannelReferenceHandler`	`getUnknownChannelReferenceHandler()`
`X11ForwardSupport`	`getX11ForwardSupport()`
`protected IoWriteFuture`	`globalRequest(Buffer buffer)` Process global requests
`protected void`	`handleChannelRegistrationFailure(Channel channel, int channelId)`
`protected IoWriteFuture`	`handleUnknownRequest(Buffer buffer, java.lang.String req, boolean wantReply)`
`boolean`	`isAllowMoreSessions()`
`protected void`	`preClose()` preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately.
`void`	`process(int cmd, Buffer buffer)` Service the request.
`int`	`registerChannel(Channel channel)` Register a newly created channel with a new unique identifier
`void`	`removePortForwardingEventListener(PortForwardingEventListener listener)` Remove a port forwarding listener
`boolean`	`removePortForwardingEventListenerManager(PortForwardingEventListenerManager manager)`
`protected void`	`requestFailure(Buffer buffer)`
`protected void`	`requestSuccess(Buffer buffer)`
`UnknownChannelReferenceHandler`	`resolveUnknownChannelReferenceHandler()` Check if current manager has a specific handler set for it - if not, try and resolve one from the "parent" container (if any)
`protected IoWriteFuture`	`sendChannelOpenFailure(Buffer buffer, int sender, int reasonCode, java.lang.String message, java.lang.String lang)`
`protected IoWriteFuture`	`sendGlobalResponse(Buffer buffer, java.lang.String req, RequestHandler.Result result, boolean wantReply)`
`protected boolean`	`sendHeartBeat()` Sends a heartbeat message/packet
`void`	`setAllowMoreSessions(boolean allow)`
`void`	`setUnknownChannelReferenceHandler(UnknownChannelReferenceHandler handler)`
`void`	`start()`
`protected java.util.concurrent.ScheduledFuture<?>`	`startHeartBeat()`
`protected void`	`stopHeartBeat()`
`java.lang.String`	`toString()`
`void`	`unregisterChannel(Channel channel)` Remove this channel from the list of managed channels

Methods inherited from class org.apache.sshd.common.util.closeable.AbstractInnerCloseable
doCloseGracefully, doCloseImmediately

Methods inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable
addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, removeCloseFutureListener

Methods inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean
getSimplifiedLogger

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.sshd.common.Service
getParentPropertyResolver

Methods inherited from interface org.apache.sshd.common.session.SessionHolder
getSessionContext

Methods inherited from interface org.apache.sshd.common.Closeable
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener

Methods inherited from interface org.apache.sshd.common.session.SessionHeartbeatController
disableSessionHeartbeat, getSessionHeartbeatInterval, getSessionHeartbeatType, setSessionHeartbeat, setSessionHeartbeat

Methods inherited from interface org.apache.sshd.common.PropertyResolver
getBoolean, getBooleanProperty, getCharset, getInteger, getIntProperty, getLong, getLongProperty, getObject, getString, getStringProperty

- Field Detail
  - MAX_CONCURRENT_CHANNELS_PROP
```
public static final java.lang.String MAX_CONCURRENT_CHANNELS_PROP
```
    Property that can be used to configure max. allowed concurrent active channels
    
    See Also:
    
    registerChannel(Channel), Constant Field Values
  - DEFAULT_MAX_CHANNELS
```
public static final int DEFAULT_MAX_CHANNELS
```
    Default value for MAX_CONCURRENT_CHANNELS_PROP is none specified
    
    See Also:
    
    Constant Field Values
  - RESPONSE_BUFFER_GROWTH_FACTOR
```
public static final java.util.function.IntUnaryOperator RESPONSE_BUFFER_GROWTH_FACTOR
```
    Default growth factor function used to resize response buffers
  - DEFAULT_SESSION_IGNORE_HEARTBEAT_STRING
```
public static final java.lang.String DEFAULT_SESSION_IGNORE_HEARTBEAT_STRING
```
    Used in SSH_MSH_IGNORE messages for the keep-alive mechanism
    
    See Also:
    
    Constant Field Values
  - channels
```
protected final java.util.Map<java.lang.Integer,Channel> channels
```
    Map of channels keyed by the identifier
  - nextChannelId
```
protected final java.util.concurrent.atomic.AtomicInteger nextChannelId
```
    Next channel identifier
  - heartbeatCount
```
protected final java.util.concurrent.atomic.AtomicLong heartbeatCount
```
  - heartBeat
```
private java.util.concurrent.ScheduledFuture<?> heartBeat
```
  - agentForwardHolder
```
private final java.util.concurrent.atomic.AtomicReference<AgentForwardSupport> agentForwardHolder
```
  - x11ForwardHolder
```
private final java.util.concurrent.atomic.AtomicReference<X11ForwardSupport> x11ForwardHolder
```
  - forwarderHolder
```
private final java.util.concurrent.atomic.AtomicReference<ForwardingFilter> forwarderHolder
```
  - allowMoreSessions
```
private final java.util.concurrent.atomic.AtomicBoolean allowMoreSessions
```
  - listeners
```
private final java.util.Collection<PortForwardingEventListener> listeners
```
  - managersHolder
```
private final java.util.Collection<PortForwardingEventListenerManager> managersHolder
```
  - properties
```
private final java.util.Map<java.lang.String,java.lang.Object> properties
```
  - listenerProxy
```
private final PortForwardingEventListener listenerProxy
```
  - sessionInstance
```
private final AbstractSession sessionInstance
```
  - unknownChannelReferenceHandler
```
private UnknownChannelReferenceHandler unknownChannelReferenceHandler
```
- Constructor Detail
  - AbstractConnectionService
```
protected AbstractConnectionService(AbstractSession session)
```
- Method Detail
  - getProperties
```
public java.util.Map<java.lang.String,java.lang.Object> getProperties()
```
    Description copied from interface: PropertyResolver
    
    A map of properties that can be used to configure the SSH server or client. This map will never be changed by either the server or client and is not supposed to be changed at runtime (changes are not bound to have any effect on a running client or server), though it may affect the creation of sessions later as these values are usually not cached.
    
    Note: the type of the mapped property should match the expected configuration value type - Long, Integer, Boolean, String, etc.... If it doesn't, the toString() result of the mapped value is used to convert it to the required type. E.g., if the mapped value is the string "1234" and the expected value is a long then it will be parsed into one. Also, if the mapped value is an Integer but a long is expected, then it will be converted into one.
    
    Specified by:
    
    getProperties in interface PropertyResolver
    
    Returns:
    
    a valid Map containing configuration values, never null. Note: may be immutable.
  - getPortForwardingEventListenerProxy
```
public PortForwardingEventListener getPortForwardingEventListenerProxy()
```
    Specified by:
    
    getPortForwardingEventListenerProxy in interface PortForwardingEventListenerManager
    
    Returns:
    
    A proxy listener representing all the currently registered listener through this manager
  - addPortForwardingEventListener
```
public void addPortForwardingEventListener(PortForwardingEventListener listener)
```
    Description copied from interface: PortForwardingEventListenerManager
    
    Add a port forwarding listener
    
    Specified by:
    
    addPortForwardingEventListener in interface PortForwardingEventListenerManager
    
    Parameters:
    
    listener - The PortForwardingEventListener to add - never null
  - removePortForwardingEventListener
```
public void removePortForwardingEventListener(PortForwardingEventListener listener)
```
    Description copied from interface: PortForwardingEventListenerManager
    
    Remove a port forwarding listener
    
    Specified by:
    
    removePortForwardingEventListener in interface PortForwardingEventListenerManager
    
    Parameters:
    
    listener - The PortForwardingEventListener to remove - ignored if null
  - getUnknownChannelReferenceHandler
```
public UnknownChannelReferenceHandler getUnknownChannelReferenceHandler()
```
    Specified by:
    
    getUnknownChannelReferenceHandler in interface UnknownChannelReferenceHandlerManager
    
    Returns:
    
    The UnknownChannelReferenceHandlerManager to use - if null then any reference to unknown channel causes an SshChannelNotFoundException
  - setUnknownChannelReferenceHandler
```
public void setUnknownChannelReferenceHandler(UnknownChannelReferenceHandler handler)
```
    Specified by:
    
    setUnknownChannelReferenceHandler in interface UnknownChannelReferenceHandlerManager
    
    Parameters:
    
    handler - The UnknownChannelReferenceHandlerManager to use - if null then any reference to unknown channel causes an SshChannelNotFoundException
  - getRegisteredManagers
```
public java.util.Collection<PortForwardingEventListenerManager> getRegisteredManagers()
```
    Specified by:
    
    getRegisteredManagers in interface PortForwardingEventListenerManagerHolder
    
    Returns:
    
    The currently registered managers. Note: it is highly recommended that implementors return either an un-modifiable collection or a copy of the current one. Callers, should avoid modifying the retrieved value.
  - addPortForwardingEventListenerManager
```
public boolean addPortForwardingEventListenerManager(PortForwardingEventListenerManager manager)
```
    Specified by:
    
    addPortForwardingEventListenerManager in interface PortForwardingEventListenerManagerHolder
  - removePortForwardingEventListenerManager
```
public boolean removePortForwardingEventListenerManager(PortForwardingEventListenerManager manager)
```
    Specified by:
    
    removePortForwardingEventListenerManager in interface PortForwardingEventListenerManagerHolder
  - getChannels
```
public java.util.Collection<Channel> getChannels()
```
  - getSession
```
public AbstractSession getSession()
```
    Specified by:
    
    getSession in interface SessionHolder<Session>
  - start
```
public void start()
```
    Specified by:
    
    start in interface Service
  - startHeartBeat
```
protected java.util.concurrent.ScheduledFuture<?> startHeartBeat()
```
  - sendHeartBeat
```
protected boolean sendHeartBeat()
```
    Sends a heartbeat message/packet
    
    Returns:
    
    true if heartbeat successfully sent
  - futureDone
```
protected void futureDone(IoWriteFuture future)
```
  - stopHeartBeat
```
protected void stopHeartBeat()
```
  - getForwardingFilter
```
public ForwardingFilter getForwardingFilter()
```
    Description copied from interface: ConnectionService
    
    Retrieve the forwarder instance
    
    Specified by:
    
    getForwardingFilter in interface ConnectionService
    
    Returns:
    
    The ForwardingFilter
  - preClose
```
protected void preClose()
```
    Description copied from class: AbstractCloseable
    
    preClose is guaranteed to be called before doCloseGracefully or doCloseImmediately. When preClose() is called, isClosing() == true
    
    Overrides:
    
    preClose in class AbstractCloseable
  - createForwardingFilter
```
protected ForwardingFilter createForwardingFilter(Session session)
```
  - getX11ForwardSupport
```
public X11ForwardSupport getX11ForwardSupport()
```
    Specified by:
    
    getX11ForwardSupport in interface ConnectionService
  - createX11ForwardSupport
```
protected X11ForwardSupport createX11ForwardSupport(Session session)
```
  - getAgentForwardSupport
```
public AgentForwardSupport getAgentForwardSupport()
```
    Specified by:
    
    getAgentForwardSupport in interface ConnectionService
  - createAgentForwardSupport
```
protected AgentForwardSupport createAgentForwardSupport(Session session)
```
  - getInnerCloseable
```
protected Closeable getInnerCloseable()
```
    Specified by:
    
    getInnerCloseable in class AbstractInnerCloseable
  - getNextChannelId
```
protected int getNextChannelId()
```
  - registerChannel
```
public int registerChannel(Channel channel)
                    throws java.io.IOException
```
    Description copied from interface: ConnectionService
    
    Register a newly created channel with a new unique identifier
    
    Specified by:
    
    registerChannel in interface ConnectionService
    
    Parameters:
    
    channel - The Channel to register
    
    Returns:
    
    The assigned id of this channel
    
    Throws:
    
    java.io.IOException - If failed to initialize and register the channel
  - handleChannelRegistrationFailure
```
protected void handleChannelRegistrationFailure(Channel channel,
                                                int channelId)
                                         throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - unregisterChannel
```
public void unregisterChannel(Channel channel)
```
    Remove this channel from the list of managed channels
    
    Specified by:
    
    unregisterChannel in interface ConnectionService
    
    Parameters:
    
    channel - the channel
  - process
```
public void process(int cmd,
                    Buffer buffer)
             throws java.lang.Exception
```
    Description copied from interface: Service
    
    Service the request.
    
    Specified by:
    
    process in interface Service
    
    Parameters:
    
    cmd - The incoming command type
    
    buffer - The Buffer containing optional command parameters
    
    Throws:
    
    java.lang.Exception - If failed to process the command
  - isAllowMoreSessions
```
public boolean isAllowMoreSessions()
```
    Specified by:
    
    isAllowMoreSessions in interface ConnectionService
  - setAllowMoreSessions
```
public void setAllowMoreSessions(boolean allow)
```
    Specified by:
    
    setAllowMoreSessions in interface ConnectionService
  - channelOpenConfirmation
```
public void channelOpenConfirmation(Buffer buffer)
                             throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - channelOpenFailure
```
public void channelOpenFailure(Buffer buffer)
                        throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - channelData
```
public void channelData(Buffer buffer)
                 throws java.io.IOException
```
    Process incoming data on a channel
    
    Parameters:
    
    buffer - the buffer containing the data
    
    Throws:
    
    java.io.IOException - if an error occurs
  - channelExtendedData
```
public void channelExtendedData(Buffer buffer)
                         throws java.io.IOException
```
    Process incoming extended data on a channel
    
    Parameters:
    
    buffer - the buffer containing the data
    
    Throws:
    
    java.io.IOException - if an error occurs
  - channelWindowAdjust
```
public void channelWindowAdjust(Buffer buffer)
                         throws java.io.IOException
```
    Process a window adjust packet on a channel
    
    Parameters:
    
    buffer - the buffer containing the window adjustment parameters
    
    Throws:
    
    java.io.IOException - if an error occurs
  - channelEof
```
public void channelEof(Buffer buffer)
                throws java.io.IOException
```
    Process end of file on a channel
    
    Parameters:
    
    buffer - the buffer containing the packet
    
    Throws:
    
    java.io.IOException - if an error occurs
  - channelClose
```
public void channelClose(Buffer buffer)
                  throws java.io.IOException
```
    Close a channel due to a close packet received
    
    Parameters:
    
    buffer - the buffer containing the packet
    
    Throws:
    
    java.io.IOException - if an error occurs
  - channelRequest
```
public void channelRequest(Buffer buffer)
                    throws java.io.IOException
```
    Service a request on a channel
    
    Parameters:
    
    buffer - the buffer containing the request
    
    Throws:
    
    java.io.IOException - if an error occurs
  - channelFailure
```
public void channelFailure(Buffer buffer)
                    throws java.io.IOException
```
    Process a failure on a channel
    
    Parameters:
    
    buffer - the buffer containing the packet
    
    Throws:
    
    java.io.IOException - if an error occurs
  - channelSuccess
```
public void channelSuccess(Buffer buffer)
                    throws java.io.IOException
```
    Process a success on a channel
    
    Parameters:
    
    buffer - the buffer containing the packet
    
    Throws:
    
    java.io.IOException - if an error occurs
  - getChannel
```
protected Channel getChannel(byte cmd,
                             Buffer buffer)
                      throws java.io.IOException
```
    Retrieve the channel designated by the given packet
    
    Parameters:
    
    cmd - The command being processed for the channel
    
    buffer - the incoming packet
    
    Returns:
    
    the target channel
    
    Throws:
    
    java.io.IOException - if the channel does not exists
  - getChannel
```
protected Channel getChannel(byte cmd,
                             int recipient,
                             Buffer buffer)
                      throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - resolveUnknownChannelReferenceHandler
```
public UnknownChannelReferenceHandler resolveUnknownChannelReferenceHandler()
```
    Description copied from interface: UnknownChannelReferenceHandlerManager
    
    Check if current manager has a specific handler set for it - if not, try and resolve one from the "parent" container (if any)
    
    Specified by:
    
    resolveUnknownChannelReferenceHandler in interface UnknownChannelReferenceHandlerManager
    
    Returns:
    
    The resolved handler instance
  - channelOpen
```
protected void channelOpen(Buffer buffer)
                    throws java.lang.Exception
```
    Throws:
    
    java.lang.Exception
  - sendChannelOpenFailure
```
protected IoWriteFuture sendChannelOpenFailure(Buffer buffer,
                                               int sender,
                                               int reasonCode,
                                               java.lang.String message,
                                               java.lang.String lang)
                                        throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - globalRequest
```
protected IoWriteFuture globalRequest(Buffer buffer)
                               throws java.lang.Exception
```
    Process global requests
    
    Parameters:
    
    buffer - The request Buffer
    
    Returns:
    
    An IoWriteFuture representing the sent packet - Note: if no reply sent then an "empty" future is returned - i.e., any added listeners are triggered immediately with a synthetic "success"
    
    Throws:
    
    java.lang.Exception - If failed to process the request
  - handleUnknownRequest
```
protected IoWriteFuture handleUnknownRequest(Buffer buffer,
                                             java.lang.String req,
                                             boolean wantReply)
                                      throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - sendGlobalResponse
```
protected IoWriteFuture sendGlobalResponse(Buffer buffer,
                                           java.lang.String req,
                                           RequestHandler.Result result,
                                           boolean wantReply)
                                    throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - requestSuccess
```
protected void requestSuccess(Buffer buffer)
                       throws java.lang.Exception
```
    Throws:
    
    java.lang.Exception
  - requestFailure
```
protected void requestFailure(Buffer buffer)
                       throws java.lang.Exception
```
    Throws:
    
    java.lang.Exception
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object

Class AbstractConnectionService

Nested Class Summary

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

Nested classes/interfaces inherited from interface org.apache.sshd.common.session.SessionHeartbeatController

Field Summary

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

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

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

Fields inherited from interface org.apache.sshd.common.session.SessionHeartbeatController

Fields inherited from interface org.apache.sshd.common.PropertyResolver

Constructor Summary

Method Summary

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

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.sshd.common.session.SessionHolder

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

Methods inherited from interface org.apache.sshd.common.session.SessionHeartbeatController

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

Field Detail

MAX_CONCURRENT_CHANNELS_PROP

DEFAULT_MAX_CHANNELS

RESPONSE_BUFFER_GROWTH_FACTOR

DEFAULT_SESSION_IGNORE_HEARTBEAT_STRING

channels

nextChannelId

heartbeatCount

heartBeat

agentForwardHolder

x11ForwardHolder

forwarderHolder

allowMoreSessions

listeners

managersHolder

properties

listenerProxy

sessionInstance

unknownChannelReferenceHandler

Constructor Detail

AbstractConnectionService

Method Detail

getProperties

getPortForwardingEventListenerProxy

addPortForwardingEventListener

removePortForwardingEventListener

getUnknownChannelReferenceHandler

setUnknownChannelReferenceHandler

getRegisteredManagers

addPortForwardingEventListenerManager

removePortForwardingEventListenerManager

getChannels

getSession

start

startHeartBeat

sendHeartBeat

futureDone

stopHeartBeat

getForwardingFilter

preClose

createForwardingFilter

getX11ForwardSupport

createX11ForwardSupport

getAgentForwardSupport

createAgentForwardSupport

getInnerCloseable

getNextChannelId

registerChannel

handleChannelRegistrationFailure

unregisterChannel

process

isAllowMoreSessions

setAllowMoreSessions

channelOpenConfirmation

channelOpenFailure

channelData

channelExtendedData

channelWindowAdjust

channelEof