public class ClientConnectionService extends AbstractConnectionService implements ClientSessionHolder
ssh-connection
service.AbstractCloseable.State
SessionHeartbeatController.HeartbeatType
Modifier and Type | Field and Description |
---|---|
protected ScheduledFuture<?> |
clientHeartbeat
Non-null only if using the "keep-alive" request mechanism
|
protected Duration |
heartbeatInterval |
protected Duration |
heartbeatReplyMaxWait |
protected String |
heartbeatRequest |
channels, DEFAULT_SESSION_IGNORE_HEARTBEAT_STRING, heartbeatCount, nextChannelId, RESPONSE_BUFFER_GROWTH_FACTOR
closeFuture, futureLock, state
log
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 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, getForwarder, getInnerCloseable, getNextChannelId, getPortForwardingEventListenerProxy, getProperties, getRegisteredManagers, getUnknownChannelReferenceHandler, globalRequest, 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
debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
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, isEmpty, isEmpty
protected final String heartbeatRequest
protected final Duration heartbeatInterval
protected final Duration heartbeatReplyMaxWait
protected 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 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
Copyright © 2008–2024 The Apache Software Foundation. All rights reserved.