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 Description AmqpInactivityMonitor(Transport next, WireFormat wireFormat)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AmqpTransport
getAmqpTransport()
void
onException(IOException error)
An unrecoverable exception has occured on the transportvoid
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
-
-
-
-
Constructor Detail
-
AmqpInactivityMonitor
public AmqpInactivityMonitor(Transport next, WireFormat wireFormat)
-
-
Method Detail
-
start
public void start() throws Exception
- Specified by:
start
in interfaceService
- Overrides:
start
in classTransportFilter
- Throws:
Exception
- See Also:
Service.start()
-
stop
public void stop() throws Exception
- Specified by:
stop
in interfaceService
- Overrides:
stop
in classTransportFilter
- 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 interfaceTransportListener
- Overrides:
onException
in classTransportFilter
-
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()
-
-