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:

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

Constructors

Constructor	Description
StompInactivityMonitor(Transport next, WireFormat wireFormat)

Method Summary

Modifier and Type	Method	Description
protected boolean	configuredOk()
protected void	processInboundWireFormatInfo(WireFormatInfo info)
protected void	processOutboundWireFormatInfo(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 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