Interface TransportListener

    • Method Detail

      • onSending

        void onSending​(List<? extends Message> messages)
        Callback method invoked when the batch of messages is being sent.
        Parameters:
        messages - the batch of messages being sent
      • onMessages

        void onMessages​(List<Message.Mutable> messages)
        Callback method invoked when a batch of message is received.
        Parameters:
        messages - the batch of messages received
      • onFailure

        void onFailure​(Throwable failure,
                       List<? extends Message> messages)
        Callback method invoked when a failure to send or receive messages occurs.
        Parameters:
        failure - the failure occurred
        messages - the batch of messages being sent