org.apache.activemq.transport
Interface TransportListener

All Known Implementing Classes:

AbstractInactivityMonitor, ActiveMQConnection, ActiveMQXAConnection, CommandJoiner, DefaultTransportListener, DiscoveryTransport, 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

void	onCommand(java.lang.Object command) called to process a command
void	onException(java.io.IOException error) An unrecoverable exception has occured on the transport
void	transportInterupted() The transport has suffered an interuption from which it hopes to recover
void	transportResumed() The transport has resumed after an interuption

Method Detail

onCommand

void onCommand(java.lang.Object command)

called to process a command

Parameters:

command -

onException

void onException(java.io.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