public class ClientConnectionService extends AbstractConnectionService implements ClientSessionHolder
ssh-connection service.AbstractCloseable.StateSessionHeartbeatController.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_FACTORcloseFuture, futureLock, statelogCLOSE_WAIT_TIMEOUT, DEFAULT_CLOSE_WAIT_TIMEOUTDEFAULT_CONNECTION_HEARTBEAT_INTERVAL, SESSION_HEARTBEAT_INTERVAL, SESSION_HEARTBEAT_TYPEEMPTY| 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, unregisterChanneldoCloseGracefully, doCloseImmediatelyaddCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, removeCloseFutureListenergetSimplifiedLoggerclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetParentPropertyResolvergetSessionContextaddCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListenerdisableSessionHeartbeat, getSessionHeartbeatInterval, getSessionHeartbeatType, setSessionHeartbeat, setSessionHeartbeatgetBoolean, getBooleanProperty, getCharset, getInteger, getIntProperty, getLong, getLongProperty, getObject, getString, getStringPropertyprotected 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
SshExceptionpublic final ClientSession getClientSession()
getClientSession in interface ClientSessionHolderClientSession usedpublic AbstractClientSession getSession()
getSession in interface SessionHolder<Session>getSession in class AbstractConnectionServicepublic void start()
start in interface Servicestart in class AbstractConnectionServiceprotected java.util.concurrent.ScheduledFuture<?> startHeartBeat()
startHeartBeat in class AbstractConnectionServiceprotected void stopHeartBeat()
stopHeartBeat in class AbstractConnectionServiceprotected boolean sendHeartBeat()
AbstractConnectionServicesendHeartBeat in class AbstractConnectionServicetrue if heartbeat successfully sentpublic AgentForwardSupport getAgentForwardSupport()
getAgentForwardSupport in interface ConnectionServicegetAgentForwardSupport in class AbstractConnectionServicepublic X11ForwardSupport getX11ForwardSupport()
getX11ForwardSupport in interface ConnectionServicegetX11ForwardSupport in class AbstractConnectionService