public class InactivityMonitor extends TransportFilter
next, transportListener
Constructor and Description |
---|
InactivityMonitor(Transport next,
WireFormat wireFormat) |
Modifier and Type | Method and Description |
---|---|
long |
getInitialDelayTime() |
long |
getReadCheckTime() |
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
|
void |
setIgnoreRemoteWireFormat(boolean val) |
void |
setInitialDelayTime(long initialDelayTime) |
void |
setKeepAliveResponseRequired(boolean val) |
void |
setReadCheckTime(long readCheckTime) |
void |
setUseKeepAlive(boolean val) |
void |
start() |
void |
stop() |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
public InactivityMonitor(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()
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 setKeepAliveResponseRequired(boolean val)
public void setUseKeepAlive(boolean val)
public void setIgnoreRemoteWireFormat(boolean val)
public long getReadCheckTime()
public void setReadCheckTime(long readCheckTime)
public long getInitialDelayTime()
public void setInitialDelayTime(long initialDelayTime)
Copyright © 2005-2012. All Rights Reserved.