Package org.apache.qpid.protonj2.client.transport

Interface TransportListener

public interface TransportListener
Listener interface that should be implemented by users of the various QpidJMS Transport classes.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    transportConnected(Transport transport)
    Called after the transport has successfully connected to the remote and performed any required handshakes such as SSL or Web Sockets handshaking and the connection is now considered open.
    void
    transportError(Throwable cause)
    Called when an error occurs during normal Transport operations such as SSL handshake or remote connection dropped.
    void
    transportInitialized(Transport transport)
    Called immediately before the transport attempts to connect to the remote peer but following all Transport initialization.
    void
    transportRead(ProtonBuffer incoming)
    Called when new incoming data has become available for processing by the Transport user.

  • Method Details

    • transportInitialized

      void transportInitialized(Transport transport)
      Called immediately before the transport attempts to connect to the remote peer but following all Transport initialization. The Transport configuration is now static and the event handler can update any internal state or configure additional resources based on the configured and prepared Transport.
      Parameters:
      transport - The transport that is now fully connected and ready to perform IO operations.

    • transportConnected

      void transportConnected(Transport transport)
      Called after the transport has successfully connected to the remote and performed any required handshakes such as SSL or Web Sockets handshaking and the connection is now considered open.
      Parameters:
      transport - The transport that is now fully connected and ready to perform IO operations.

    • transportRead

      void transportRead(ProtonBuffer incoming)
      Called when new incoming data has become available for processing by the Transport user.
      Parameters:
      incoming - the next incoming packet of data.

    • transportError

      void transportError(Throwable cause)
      Called when an error occurs during normal Transport operations such as SSL handshake or remote connection dropped. Once this error callback is triggered the Transport is considered to be failed and should be closed.
      Parameters:
      cause - the error that triggered this event.