Package org.apache.activemq.transport.stomp

Class StompInactivityMonitor

java.lang.Object
org.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.AbstractInactivityMonitor
org.apache.activemq.transport.stomp.StompInactivityMonitor
All Implemented Interfaces:
org.apache.activemq.Service, org.apache.activemq.transport.Transport, org.apache.activemq.transport.TransportListener
public class StompInactivityMonitor extends org.apache.activemq.transport.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

    READ_CHECK_THREAD_NAME, wireFormat, WRITE_CHECK_THREAD_NAME

    Fields inherited from class org.apache.activemq.transport.TransportFilter

    next, transportListener

  • Constructor Summary

    Constructors
    Constructor
    Description
    StompInactivityMonitor(org.apache.activemq.transport.Transport next, org.apache.activemq.wireformat.WireFormat wireFormat)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected boolean
    configuredOk()
     
    protected void
    processInboundWireFormatInfo(org.apache.activemq.command.WireFormatInfo info)
     
    protected void
    processOutboundWireFormatInfo(org.apache.activemq.command.WireFormatInfo info)
     
    void
    startMonitoring()
     

    Methods inherited from class org.apache.activemq.transport.AbstractInactivityMonitor

    getConnectAttemptTimeout, getInitialDelayTime, getReadCheckTime, getWriteCheckTime, isKeepAliveResponseRequired, isMonitorStarted, onCommand, oneway, onException, setConnectAttemptTimeout, setInitialDelayTime, setKeepAliveResponseRequired, setReadCheckTime, setUseKeepAlive, setWriteCheckTime, start, startConnectCheckTask, startConnectCheckTask, startMonitorThreads, stop, stopConnectCheckTask, stopMonitorThreads

    Methods inherited from class org.apache.activemq.transport.TransportFilter

    asyncRequest, getNext, getPeerCertificates, getReceiveCounter, getRemoteAddress, getTransportListener, getWireFormat, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setPeerCertificates, setTransportListener, toString, transportInterupted, transportResumed, updateURIs

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • StompInactivityMonitor

      public StompInactivityMonitor(org.apache.activemq.transport.Transport next, org.apache.activemq.wireformat.WireFormat wireFormat)

  • Method Details

    • startMonitoring

      public void startMonitoring() throws IOException
      Throws:
      IOException

    • processInboundWireFormatInfo

      protected void processInboundWireFormatInfo(org.apache.activemq.command.WireFormatInfo info) throws IOException
      Specified by:
      processInboundWireFormatInfo in class org.apache.activemq.transport.AbstractInactivityMonitor
      Throws:
      IOException

    • processOutboundWireFormatInfo

      protected void processOutboundWireFormatInfo(org.apache.activemq.command.WireFormatInfo info) throws IOException
      Specified by:
      processOutboundWireFormatInfo in class org.apache.activemq.transport.AbstractInactivityMonitor
      Throws:
      IOException

    • configuredOk

      protected boolean configuredOk() throws IOException
      Specified by:
      configuredOk in class org.apache.activemq.transport.AbstractInactivityMonitor
      Throws:
      IOException