org.apache.activemq.transport
Class InactivityMonitor

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by org.apache.activemq.transport.AbstractInactivityMonitor
          extended by 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
InactivityMonitor(Transport next, WireFormat wireFormat)
           
 
Method Summary
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 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)


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.