Package org.apache.activemq.transport
Interface TransportListener
-
- All Known Implementing Classes:
AbstractInactivityMonitor,ActiveMQConnection,ActiveMQXAConnection,AmqpInactivityMonitor,AmqpTransportFilter,CommandJoiner,DefaultTransportListener,DiscoveryTransport,HttpInactivityMonitor,InactivityMonitor,MarshallingTransportFilter,MockTransport,MQTTInactivityMonitor,MQTTTransportFilter,MutexTransport,ReliableTransport,ResponseCorrelator,ResponseRedirectInterceptor,StompInactivityMonitor,StompTransportFilter,ThreadNameFilter,TransportFilter,TransportLogger,WireFormatNegotiator,WriteTimeoutFilter
public interface TransportListenerAn asynchronous listener of commands
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidonCommand(Object command)called to process a commandvoidonException(IOException error)An unrecoverable exception has occured on the transportvoidtransportInterupted()The transport has suffered an interuption from which it hopes to recovervoidtransportResumed()The transport has resumed after an interuption
-
-
-
Method Detail
-
onCommand
void onCommand(Object command)
called to process a command- Parameters:
command-
-
onException
void onException(IOException error)
An unrecoverable exception has occured on the transport- Parameters:
error-
-
transportInterupted
void transportInterupted()
The transport has suffered an interuption from which it hopes to recover
-
transportResumed
void transportResumed()
The transport has resumed after an interuption
-
-