org.apache.activemq.transport.amqp

Class AmqpInactivityMonitor

java.lang.Object

org.apache.activemq.transport.TransportFilter

org.apache.activemq.transport.amqp.AmqpInactivityMonitor

All Implemented Interfaces:

Service, Transport, TransportListener

public class AmqpInactivityMonitor
extends TransportFilter

Field Summary

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

next, transportListener

Constructor Summary

Constructors

Constructor and Description
AmqpInactivityMonitor(Transport next, WireFormat wireFormat)

Method Summary

Modifier and Type	Method and Description
AmqpTransport	getAmqpTransport()
void	onException(IOException error) An unrecoverable exception has occured on the transport
void	setAmqpTransport(AmqpTransport amqpTransport)
void	start()
void	startConnectionTimeoutChecker(long connectionTimeout)
void	startKeepAliveTask(long nextKeepAliveCheck) Starts the keep alive task which will run after the given delay.
void	stop()
void	stopConnectionTimeoutChecker()
void	stopKeepAliveTask()

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

asyncRequest, getNext, getPeerCertificates, getReceiveCounter, getRemoteAddress, getTransportListener, getWireFormat, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onCommand, oneway, reconnect, request, request, setPeerCertificates, setTransportListener, toString, transportInterupted, transportResumed, updateURIs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

AmqpInactivityMonitor

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

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

setAmqpTransport

public void setAmqpTransport(AmqpTransport amqpTransport)

getAmqpTransport

public AmqpTransport getAmqpTransport()

startConnectionTimeoutChecker

public void startConnectionTimeoutChecker(long connectionTimeout)

startKeepAliveTask

public void startKeepAliveTask(long nextKeepAliveCheck)

Starts the keep alive task which will run after the given delay.

Parameters:

nextKeepAliveCheck - time in milliseconds to wait before performing the next keep-alive check.

stopConnectionTimeoutChecker

public void stopConnectionTimeoutChecker()

stopKeepAliveTask

public void stopKeepAliveTask()