org.apache.activemq.transport
Class AbstractInactivityMonitor

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by org.apache.activemq.transport.AbstractInactivityMonitor
All Implemented Interfaces:
Service, Transport, TransportListener
Direct Known Subclasses:
InactivityMonitor, StompInactivityMonitor

public abstract class AbstractInactivityMonitor
extends TransportFilter

Used to make sure that commands are arriving periodically from the peer of the transport.


Field Summary
protected  WireFormat wireFormat
           
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
next, transportListener
 
Constructor Summary
AbstractInactivityMonitor(Transport next, WireFormat wireFormat)
           
 
Method Summary
protected abstract  boolean configuredOk()
           
 long getInitialDelayTime()
           
 long getReadCheckTime()
           
 long getWriteCheckTime()
           
 boolean isKeepAliveResponseRequired()
           
 boolean isMonitorStarted()
           
 void onCommand(Object command)
          called to process a command
 void oneway(Object o)
          A one way asynchronous send
 void onException(IOException error)
          An unrecoverable exception has occured on the transport
protected abstract  void processInboundWireFormatInfo(WireFormatInfo info)
           
protected abstract  void processOutboundWireFormatInfo(WireFormatInfo info)
           
 void setInitialDelayTime(long initialDelayTime)
           
 void setKeepAliveResponseRequired(boolean value)
           
 void setReadCheckTime(long readCheckTime)
           
 void setUseKeepAlive(boolean val)
           
 void setWriteCheckTime(long writeCheckTime)
           
 void start()
           
protected  void startMonitorThreads()
           
 void stop()
           
protected  void 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
 

Field Detail

wireFormat

protected WireFormat wireFormat
Constructor Detail

AbstractInactivityMonitor

public AbstractInactivityMonitor(Transport next,
                                 WireFormat wireFormat)
Method Detail

start

public void start()
           throws Exception
Specified by:
start in interface Service
Overrides:
start in class TransportFilter
Throws:
Exception
See Also:
Service.start()

stop

public void stop()
          throws Exception
Specified by:
stop in interface Service
Overrides:
stop in class TransportFilter
Throws:
Exception
See Also:
Service.stop()

processInboundWireFormatInfo

protected abstract void processInboundWireFormatInfo(WireFormatInfo info)
                                              throws IOException
Throws:
IOException

processOutboundWireFormatInfo

protected abstract void processOutboundWireFormatInfo(WireFormatInfo info)
                                               throws IOException
Throws:
IOException

onCommand

public void onCommand(Object command)
Description copied from interface: TransportListener
called to process a command

Specified by:
onCommand in interface TransportListener
Overrides:
onCommand in class TransportFilter

oneway

public void oneway(Object o)
            throws IOException
Description copied from interface: Transport
A one way asynchronous send

Specified by:
oneway in interface Transport
Overrides:
oneway in class TransportFilter
Throws:
IOException

onException

public void onException(IOException error)
Description copied from interface: TransportListener
An unrecoverable exception has occured on the transport

Specified by:
onException in interface TransportListener
Overrides:
onException in class TransportFilter

setUseKeepAlive

public void setUseKeepAlive(boolean val)

getReadCheckTime

public long getReadCheckTime()

setReadCheckTime

public void setReadCheckTime(long readCheckTime)

getWriteCheckTime

public long getWriteCheckTime()

setWriteCheckTime

public void setWriteCheckTime(long writeCheckTime)

getInitialDelayTime

public long getInitialDelayTime()

setInitialDelayTime

public void setInitialDelayTime(long initialDelayTime)

isKeepAliveResponseRequired

public boolean isKeepAliveResponseRequired()

setKeepAliveResponseRequired

public void setKeepAliveResponseRequired(boolean value)

isMonitorStarted

public boolean isMonitorStarted()

startMonitorThreads

protected void startMonitorThreads()
                            throws IOException
Throws:
IOException

configuredOk

protected abstract boolean configuredOk()
                                 throws IOException
Throws:
IOException

stopMonitorThreads

protected void stopMonitorThreads()


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.