public class AmqpInactivityMonitor extends TransportFilter
next, transportListener
Constructor and Description |
---|
AmqpInactivityMonitor(Transport next,
WireFormat wireFormat) |
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() |
asyncRequest, getNext, getPeerCertificates, getReceiveCounter, getRemoteAddress, getTransportListener, getWireFormat, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onCommand, oneway, reconnect, request, request, setPeerCertificates, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
public AmqpInactivityMonitor(Transport next, WireFormat wireFormat)
public void start() throws Exception
start
in interface Service
start
in class TransportFilter
Exception
Service.start()
public void stop() throws Exception
stop
in interface Service
stop
in class TransportFilter
Exception
Service.stop()
public void onException(IOException error)
TransportListener
onException
in interface TransportListener
onException
in class TransportFilter
public void setAmqpTransport(AmqpTransport amqpTransport)
public AmqpTransport getAmqpTransport()
public void startConnectionTimeoutChecker(long connectionTimeout)
public void startKeepAliveTask(long nextKeepAliveCheck)
nextKeepAliveCheck
- time in milliseconds to wait before performing the next keep-alive check.public void stopConnectionTimeoutChecker()
public void stopKeepAliveTask()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.