public class ClientConnectionService extends AbstractConnectionService implements ClientSessionHolder
ssh-connection
service.AbstractCloseable.State
SessionHeartbeatController.HeartbeatType
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.ScheduledFuture<?> |
clientHeartbeat
Non-null only if using the "keep-alive" request mechanism
|
protected long |
heartbeatInterval |
protected long |
heartbeatReplyMaxWait |
protected java.lang.String |
heartbeatRequest |
channels, DEFAULT_MAX_CHANNELS, DEFAULT_SESSION_IGNORE_HEARTBEAT_STRING, heartbeatCount, MAX_CONCURRENT_CHANNELS_PROP, nextChannelId, RESPONSE_BUFFER_GROWTH_FACTOR
closeFuture, futureLock, state
log
CLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUT
DEFAULT_CONNECTION_HEARTBEAT_INTERVAL, SESSION_HEARTBEAT_INTERVAL, SESSION_HEARTBEAT_TYPE
EMPTY
Constructor and Description |
---|
ClientConnectionService(AbstractClientSession s) |
Modifier and Type | Method and Description |
---|---|
AgentForwardSupport |
getAgentForwardSupport() |
ClientSession |
getClientSession() |
AbstractClientSession |
getSession() |
X11ForwardSupport |
getX11ForwardSupport() |
protected boolean |
sendHeartBeat()
Sends a heartbeat message/packet
|
void |
start() |
protected java.util.concurrent.ScheduledFuture<?> |
startHeartBeat() |
protected void |
stopHeartBeat() |
addPortForwardingEventListener, addPortForwardingEventListenerManager, channelClose, channelData, channelEof, channelExtendedData, channelFailure, channelOpen, channelOpenConfirmation, channelOpenFailure, channelRequest, channelSuccess, channelWindowAdjust, createAgentForwardSupport, createForwardingFilter, createX11ForwardSupport, futureDone, getChannel, getChannel, getChannels, getForwardingFilter, getInnerCloseable, getNextChannelId, getPortForwardingEventListenerProxy, getProperties, getRegisteredManagers, getUnknownChannelReferenceHandler, globalRequest, handleChannelRegistrationFailure, handleUnknownRequest, isAllowMoreSessions, preClose, process, registerChannel, removePortForwardingEventListener, removePortForwardingEventListenerManager, requestFailure, requestSuccess, resolveUnknownChannelReferenceHandler, sendChannelOpenFailure, sendGlobalResponse, setAllowMoreSessions, setUnknownChannelReferenceHandler, toString, unregisterChannel
doCloseGracefully, doCloseImmediately
addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, removeCloseFutureListener
getSimplifiedLogger
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getParentPropertyResolver
getSessionContext
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
disableSessionHeartbeat, getSessionHeartbeatInterval, getSessionHeartbeatType, setSessionHeartbeat, setSessionHeartbeat
getBoolean, getBooleanProperty, getCharset, getInteger, getIntProperty, getLong, getLongProperty, getObject, getString, getStringProperty
protected final java.lang.String heartbeatRequest
protected final long heartbeatInterval
protected final long heartbeatReplyMaxWait
protected java.util.concurrent.ScheduledFuture<?> clientHeartbeat
public ClientConnectionService(AbstractClientSession s) throws SshException
SshException
public final ClientSession getClientSession()
getClientSession
in interface ClientSessionHolder
ClientSession
usedpublic AbstractClientSession getSession()
getSession
in interface SessionHolder<Session>
getSession
in class AbstractConnectionService
public void start()
start
in interface Service
start
in class AbstractConnectionService
protected java.util.concurrent.ScheduledFuture<?> startHeartBeat()
startHeartBeat
in class AbstractConnectionService
protected void stopHeartBeat()
stopHeartBeat
in class AbstractConnectionService
protected boolean sendHeartBeat()
AbstractConnectionService
sendHeartBeat
in class AbstractConnectionService
true
if heartbeat successfully sentpublic AgentForwardSupport getAgentForwardSupport()
getAgentForwardSupport
in interface ConnectionService
getAgentForwardSupport
in class AbstractConnectionService
public X11ForwardSupport getX11ForwardSupport()
getX11ForwardSupport
in interface ConnectionService
getX11ForwardSupport
in class AbstractConnectionService