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.
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 |
InactivityMonitor
public InactivityMonitor(Transport next,
WireFormat wireFormat)
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)
Copyright © 2005-2012. All Rights Reserved.