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

      All Methods Instance Methods Abstract Methods 
      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​(java.lang.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 Detail

      • 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​(java.lang.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.