public abstract class AbstractInactivityMonitor extends TransportFilter
Modifier and Type | Field and Description |
---|---|
protected WireFormat |
wireFormat |
next, transportListener
Constructor and Description |
---|
AbstractInactivityMonitor(Transport next,
WireFormat wireFormat) |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
configuredOk() |
long |
getConnectAttemptTimeout() |
long |
getInitialDelayTime() |
long |
getReadCheckTime() |
long |
getWriteCheckTime() |
boolean |
isKeepAliveResponseRequired() |
boolean |
isMonitorStarted() |
void |
onCommand(Object command)
called to process a command
|
void |
oneway(Object o)
A one way asynchronous send
|
void |
onException(IOException error)
An unrecoverable exception has occured on the transport
|
protected abstract void |
processInboundWireFormatInfo(WireFormatInfo info) |
protected abstract void |
processOutboundWireFormatInfo(WireFormatInfo info) |
void |
setConnectAttemptTimeout(long connectionTimeout) |
void |
setInitialDelayTime(long initialDelayTime) |
void |
setKeepAliveResponseRequired(boolean value) |
void |
setReadCheckTime(long readCheckTime) |
void |
setUseKeepAlive(boolean val) |
void |
setWriteCheckTime(long writeCheckTime) |
void |
start() |
void |
startConnectCheckTask() |
void |
startConnectCheckTask(long connectionTimeout) |
protected void |
startMonitorThreads() |
void |
stop() |
void |
stopConnectCheckTask() |
protected void |
stopMonitorThreads() |
asyncRequest, getNext, getPeerCertificates, getReceiveCounter, getRemoteAddress, getTransportListener, getWireFormat, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setPeerCertificates, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
protected WireFormat wireFormat
public AbstractInactivityMonitor(Transport next, WireFormat wireFormat)
public void start() throws Exception
start
in interface Service
start
in class TransportFilter
Exception
Service.start()
public void stop() throws Exception
stop
in interface Service
stop
in class TransportFilter
Exception
Service.stop()
protected abstract void processInboundWireFormatInfo(WireFormatInfo info) throws IOException
IOException
protected abstract void processOutboundWireFormatInfo(WireFormatInfo info) throws IOException
IOException
public void onCommand(Object command)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void oneway(Object o) throws IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
IOException
public void onException(IOException error)
TransportListener
onException
in interface TransportListener
onException
in class TransportFilter
public void setUseKeepAlive(boolean val)
public long getConnectAttemptTimeout()
public void setConnectAttemptTimeout(long connectionTimeout)
public long getReadCheckTime()
public void setReadCheckTime(long readCheckTime)
public long getWriteCheckTime()
public void setWriteCheckTime(long writeCheckTime)
public long getInitialDelayTime()
public void setInitialDelayTime(long initialDelayTime)
public boolean isKeepAliveResponseRequired()
public void setKeepAliveResponseRequired(boolean value)
public boolean isMonitorStarted()
protected abstract boolean configuredOk() throws IOException
IOException
public void startConnectCheckTask()
public void startConnectCheckTask(long connectionTimeout)
public void stopConnectCheckTask()
protected void startMonitorThreads() throws IOException
IOException
protected void stopMonitorThreads()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.