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 java.time.Duration |
heartbeatInterval |
protected java.time.Duration |
heartbeatReplyMaxWait |
protected java.lang.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 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, getForwarder, 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
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
protected final java.lang.String heartbeatRequest
protected final java.time.Duration heartbeatInterval
protected final java.time.Duration 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