org.apache.activemq.transport
Class InactivityMonitor

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by 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$

Field Summary
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
next, transportListener
 
Constructor Summary
InactivityMonitor(Transport next)
           
 
Method Summary
 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
 void stop()
           
 
Methods inherited from class org.apache.activemq.transport.TransportFilter
asyncRequest, getNext, getRemoteAddress, getTransportListener, narrow, request, request, setTransportListener, start, toString, transportInterupted, transportResumed
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

InactivityMonitor

public InactivityMonitor(Transport next)
Method Detail

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


Copyright © 2011 Apache Software Foundation. All Rights Reserved.