Interface TransportListener

All Known Implementing Classes:
AbstractInactivityMonitor, ActiveMQConnection, ActiveMQXAConnection, CommandJoiner, DefaultTransportListener, DiscoveryTransport, InactivityMonitor, MarshallingTransportFilter, MockTransport, MutexTransport, ReliableTransport, ResponseCorrelator, ResponseRedirectInterceptor, ThreadNameFilter, TransportFilter, WireFormatNegotiator, WriteTimeoutFilter
public interface TransportListener
An asynchronous listener of commands

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onCommand(Object command)
    called to process a command
    void
    onException(IOException error)
    An unrecoverable exception has occurred 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 Details

    • onCommand

      void onCommand(Object command)
      called to process a command
      Parameters:
      command -

    • onException

      void onException(IOException error)
      An unrecoverable exception has occurred 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