org.apache.activemq.transport.stomp
Class StompInactivityMonitor

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by org.apache.activemq.transport.AbstractInactivityMonitor
          extended by org.apache.activemq.transport.stomp.StompInactivityMonitor
All Implemented Interfaces:
Service, Transport, TransportListener

public class StompInactivityMonitor
extends AbstractInactivityMonitor

Used to make sure that commands are arriving periodically from the peer of the transport.


Field Summary
 
Fields inherited from class org.apache.activemq.transport.AbstractInactivityMonitor
wireFormat
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
next, transportListener
 
Constructor Summary
StompInactivityMonitor(Transport next, WireFormat wireFormat)
           
 
Method Summary
protected  boolean configuredOk()
           
protected  void processInboundWireFormatInfo(WireFormatInfo info)
           
protected  void processOutboundWireFormatInfo(WireFormatInfo info)
           
 void startMonitoring()
           
 
Methods inherited from class org.apache.activemq.transport.AbstractInactivityMonitor
getInitialDelayTime, getReadCheckTime, getWriteCheckTime, isKeepAliveResponseRequired, isMonitorStarted, onCommand, oneway, onException, setInitialDelayTime, setKeepAliveResponseRequired, setReadCheckTime, setUseKeepAlive, setWriteCheckTime, start, startMonitorThreads, stop, stopMonitorThreads
 
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
 

Constructor Detail

StompInactivityMonitor

public StompInactivityMonitor(Transport next,
                              WireFormat wireFormat)
Method Detail

startMonitoring

public void startMonitoring()
                     throws IOException
Throws:
IOException

processInboundWireFormatInfo

protected void processInboundWireFormatInfo(WireFormatInfo info)
                                     throws IOException
Specified by:
processInboundWireFormatInfo in class AbstractInactivityMonitor
Throws:
IOException

processOutboundWireFormatInfo

protected void processOutboundWireFormatInfo(WireFormatInfo info)
                                      throws IOException
Specified by:
processOutboundWireFormatInfo in class AbstractInactivityMonitor
Throws:
IOException

configuredOk

protected boolean configuredOk()
                        throws IOException
Specified by:
configuredOk in class AbstractInactivityMonitor
Throws:
IOException


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.