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.
- Version:
- $Revision$
Methods inherited from class org.apache.activemq.transport.TransportFilter |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, narrow, reconnect, request, request, setTransportListener, start, toString, transportInterupted, transportResumed |
InactivityMonitor
public InactivityMonitor(Transport next,
WireFormat wireFormat)
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
in class TransportFilter
- Throws:
Exception
- See Also:
Service.stop()
onCommand
public void onCommand(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(Object o)
throws IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Specified by:
oneway
in interface Transport
- Overrides:
oneway
in class TransportFilter
- Throws:
IOException
onException
public void onException(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)
setIgnoreRemoteWireFormat
public void setIgnoreRemoteWireFormat(boolean val)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.