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 |
getInitialDelayTime() |
long |
getReadCheckTime() |
long |
getWriteCheckTime() |
boolean |
isKeepAliveResponseRequired() |
boolean |
isMonitorStarted() |
void |
onCommand(java.lang.Object command)
called to process a command
|
void |
oneway(java.lang.Object o)
A one way asynchronous send
|
void |
onException(java.io.IOException error)
An unrecoverable exception has occured on the transport
|
protected abstract void |
processInboundWireFormatInfo(WireFormatInfo info) |
protected abstract void |
processOutboundWireFormatInfo(WireFormatInfo info) |
void |
setInitialDelayTime(long initialDelayTime) |
void |
setKeepAliveResponseRequired(boolean value) |
void |
setReadCheckTime(long readCheckTime) |
void |
setUseKeepAlive(boolean val) |
void |
setWriteCheckTime(long writeCheckTime) |
void |
start() |
protected void |
startMonitorThreads() |
void |
stop() |
protected void |
stopMonitorThreads() |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
protected WireFormat wireFormat
public AbstractInactivityMonitor(Transport next, WireFormat wireFormat)
public void start() throws java.lang.Exception
start
in interface Service
start
in class TransportFilter
java.lang.Exception
Service.start()
public void stop() throws java.lang.Exception
stop
in interface Service
stop
in class TransportFilter
java.lang.Exception
Service.stop()
protected abstract void processInboundWireFormatInfo(WireFormatInfo info) throws java.io.IOException
java.io.IOException
protected abstract void processOutboundWireFormatInfo(WireFormatInfo info) throws java.io.IOException
java.io.IOException
public void onCommand(java.lang.Object command)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void oneway(java.lang.Object o) throws java.io.IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
java.io.IOException
public void onException(java.io.IOException error)
TransportListener
onException
in interface TransportListener
onException
in class TransportFilter
public void setUseKeepAlive(boolean val)
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 void startMonitorThreads() throws java.io.IOException
java.io.IOException
protected abstract boolean configuredOk() throws java.io.IOException
java.io.IOException
protected void stopMonitorThreads()
Copyright © 2005-2017. All Rights Reserved.