org.apache.activemq.transport

Class InactivityMonitor

java.lang.Object

org.apache.activemq.transport.TransportFilter

org.apache.activemq.transport.AbstractInactivityMonitor

org.apache.activemq.transport.InactivityMonitor

All Implemented Interfaces:

Service, Transport, TransportListener

public class InactivityMonitor
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 and Description
InactivityMonitor(Transport next, WireFormat wireFormat)

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	configuredOk()
boolean	isIgnoreAllWireFormatInfo()
boolean	isIgnoreRemoteWireFormat()
protected void	processInboundWireFormatInfo(WireFormatInfo info)
protected void	processOutboundWireFormatInfo(WireFormatInfo info)
void	setIgnoreAllWireFormatInfo(boolean ignoreAllWireFormatInfo)
void	setIgnoreRemoteWireFormat(boolean ignoreRemoteWireFormat)
protected void	startMonitorThreads()

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

getInitialDelayTime, getReadCheckTime, getWriteCheckTime, isKeepAliveResponseRequired, isMonitorStarted, onCommand, oneway, onException, setInitialDelayTime, setKeepAliveResponseRequired, setReadCheckTime, setUseKeepAlive, setWriteCheckTime, start, 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

InactivityMonitor

public InactivityMonitor(Transport next,
                 WireFormat wireFormat)

Method Detail

processInboundWireFormatInfo

protected void processInboundWireFormatInfo(WireFormatInfo info)
                                     throws java.io.IOException

Specified by:

processInboundWireFormatInfo in class AbstractInactivityMonitor

Throws:

java.io.IOException

processOutboundWireFormatInfo

protected void processOutboundWireFormatInfo(WireFormatInfo info)
                                      throws java.io.IOException

Specified by:

processOutboundWireFormatInfo in class AbstractInactivityMonitor

Throws:

java.io.IOException

startMonitorThreads

protected void startMonitorThreads()
                            throws java.io.IOException

Overrides:

startMonitorThreads in class AbstractInactivityMonitor

Throws:

java.io.IOException

configuredOk

protected boolean configuredOk()
                        throws java.io.IOException

Specified by:

configuredOk in class AbstractInactivityMonitor

Throws:

java.io.IOException

isIgnoreAllWireFormatInfo

public boolean isIgnoreAllWireFormatInfo()

setIgnoreAllWireFormatInfo

public void setIgnoreAllWireFormatInfo(boolean ignoreAllWireFormatInfo)

isIgnoreRemoteWireFormat

public boolean isIgnoreRemoteWireFormat()

setIgnoreRemoteWireFormat

public void setIgnoreRemoteWireFormat(boolean ignoreRemoteWireFormat)