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)
void	start()
protected void	startMonitorThreads()

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

getConnectAttemptTimeout, getInitialDelayTime, getReadCheckTime, getWriteCheckTime, isKeepAliveResponseRequired, isMonitorStarted, onCommand, oneway, onException, setConnectAttemptTimeout, setInitialDelayTime, setKeepAliveResponseRequired, setReadCheckTime, setUseKeepAlive, setWriteCheckTime, startConnectCheckTask, startConnectCheckTask, stop, stopConnectCheckTask, 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

start

public void start()
           throws Exception

Specified by:

start in interface Service

Overrides:

start in class AbstractInactivityMonitor

Throws:

Exception

See Also:

Service.start()

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

startMonitorThreads

protected void startMonitorThreads()
                            throws IOException

Overrides:

startMonitorThreads in class AbstractInactivityMonitor

Throws:

IOException

configuredOk

protected boolean configuredOk()
                        throws IOException

Specified by:

configuredOk in class AbstractInactivityMonitor

Throws:

IOException

isIgnoreAllWireFormatInfo

public boolean isIgnoreAllWireFormatInfo()

setIgnoreAllWireFormatInfo

public void setIgnoreAllWireFormatInfo(boolean ignoreAllWireFormatInfo)

isIgnoreRemoteWireFormat

public boolean isIgnoreRemoteWireFormat()

setIgnoreRemoteWireFormat

public void setIgnoreRemoteWireFormat(boolean ignoreRemoteWireFormat)