org.apache.activemq.transport
Class InactivityMonitor
java.lang.Object
org.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.InactivityMonitor
- All Implemented Interfaces:
- Service, Transport, TransportListener
public class InactivityMonitor
- extends TransportFilter
Used to make sure that commands are arriving periodically from the peer of
the transport.
Methods inherited from class org.apache.activemq.transport.TransportFilter |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
InactivityMonitor
public InactivityMonitor(Transport next,
WireFormat wireFormat)
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface Service
- Overrides:
start
in class TransportFilter
- Throws:
java.lang.Exception
- See Also:
Service.start()
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
in class TransportFilter
- Throws:
java.lang.Exception
- See Also:
Service.stop()
onCommand
public void onCommand(java.lang.Object command)
- Description copied from interface:
TransportListener
- called to process a command
- Specified by:
onCommand
in interface TransportListener
- Overrides:
onCommand
in class TransportFilter
oneway
public void oneway(java.lang.Object o)
throws java.io.IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Specified by:
oneway
in interface Transport
- Overrides:
oneway
in class TransportFilter
- Throws:
java.io.IOException
onException
public void onException(java.io.IOException error)
- Description copied from interface:
TransportListener
- An unrecoverable exception has occured on the transport
- Specified by:
onException
in interface TransportListener
- Overrides:
onException
in class TransportFilter
setKeepAliveResponseRequired
public void setKeepAliveResponseRequired(boolean val)
setUseKeepAlive
public void setUseKeepAlive(boolean val)
setIgnoreRemoteWireFormat
public void setIgnoreRemoteWireFormat(boolean val)
getReadCheckTime
public long getReadCheckTime()
setReadCheckTime
public void setReadCheckTime(long readCheckTime)
getInitialDelayTime
public long getInitialDelayTime()
setInitialDelayTime
public void setInitialDelayTime(long initialDelayTime)
Copyright © 2005-2012. All Rights Reserved.