org.apache.activemq.transport

Class AbstractInactivityMonitor

java.lang.Object

org.apache.activemq.transport.TransportFilter

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

Fields

Modifier and Type	Field and Description
protected WireFormat	wireFormat

Fields inherited from class org.apache.activemq.transport.TransportFilter

next, transportListener

Constructor Summary

Constructors

Constructor and Description
AbstractInactivityMonitor(Transport next, WireFormat wireFormat)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract boolean	configuredOk()
long	getConnectAttemptTimeout()
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	setConnectAttemptTimeout(long connectionTimeout)
void	setInitialDelayTime(long initialDelayTime)
void	setKeepAliveResponseRequired(boolean value)
void	setReadCheckTime(long readCheckTime)
void	setUseKeepAlive(boolean val)
void	setWriteCheckTime(long writeCheckTime)
void	start()
void	startConnectCheckTask()
void	startConnectCheckTask(long connectionTimeout)
protected void	startMonitorThreads()
void	stop()
void	stopConnectCheckTask()
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)

getConnectAttemptTimeout

public long getConnectAttemptTimeout()

setConnectAttemptTimeout

public void setConnectAttemptTimeout(long connectionTimeout)

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()

configuredOk

protected abstract boolean configuredOk()
                                 throws IOException

Throws:

IOException

startConnectCheckTask

public void startConnectCheckTask()

startConnectCheckTask

public void startConnectCheckTask(long connectionTimeout)

stopConnectCheckTask

public void stopConnectCheckTask()

startMonitorThreads

protected void startMonitorThreads()
                            throws IOException

Throws:

IOException

stopMonitorThreads

protected void stopMonitorThreads()