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 TransportListener
An asynchronous listener of commands
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
onCommand(Object command)
called to process a commandvoid
onException(IOException error)
An unrecoverable exception has occured on the transportvoid
transportInterupted()
The transport has suffered an interuption from which it hopes to recovervoid
transportResumed()
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
-
-