org.apache.activemq.transport
Class InactivityMonitor

java.lang.Object
  org.apache.activemq.transport.TransportFilter
      org.apache.activemq.transport.InactivityMonitor

All Implemented Interfaces:

Service, Transport, TransportListener

public class InactivityMonitor
extends TransportFilter

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.TransportFilter

next, transportListener

Constructor Summary

InactivityMonitor(Transport next, WireFormat wireFormat)

Method Summary

long	getInitialDelayTime()
long	getReadCheckTime()
void	onCommand(java.lang.Object command) called to process a command
void	oneway(java.lang.Object o) A one way asynchronous send
void	onException(java.io.IOException error) An unrecoverable exception has occured on the transport
void	setIgnoreRemoteWireFormat(boolean val)
void	setInitialDelayTime(long initialDelayTime)
void	setKeepAliveResponseRequired(boolean val)
void	setReadCheckTime(long readCheckTime)
void	setUseKeepAlive(boolean val)
void	start()
void	stop()

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 java.lang.Exception

Specified by:

start in interface Service

Overrides:

start in class TransportFilter

Throws:

java.lang.Exception

See Also:

Service.start()

stop

public void stop()
          throws java.lang.Exception

Specified by:

stop in interface Service

Overrides:

stop in class TransportFilter

Throws:

java.lang.Exception

See Also:

Service.stop()

onCommand

public void onCommand(java.lang.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(java.lang.Object o)
            throws java.io.IOException

Description copied from interface: Transport

A one way asynchronous send

Specified by:

oneway in interface Transport

Overrides:

oneway in class TransportFilter

Throws:

java.io.IOException

onException

public void onException(java.io.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

setKeepAliveResponseRequired

public void setKeepAliveResponseRequired(boolean val)

setUseKeepAlive

public void setUseKeepAlive(boolean val)

setIgnoreRemoteWireFormat

public void setIgnoreRemoteWireFormat(boolean val)

getReadCheckTime

public long getReadCheckTime()

setReadCheckTime

public void setReadCheckTime(long readCheckTime)

getInitialDelayTime

public long getInitialDelayTime()

setInitialDelayTime

public void setInitialDelayTime(long initialDelayTime)