Interface OutgoingMessageQueue.MessageQueueListener

  • Enclosing interface:
    OutgoingMessageQueue

    public static interface OutgoingMessageQueue.MessageQueueListener
    Receive notification of queue events.
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void dataBytesSent​(int byte_count)
      The given number of (piece) data bytes has been written to the transport.
      void flush()  
      boolean messageAdded​(Message message)
      The given message has just been added to the queue.
      void messageQueued​(Message message)
      The given message has just been queued for sending out the transport.
      void messageRemoved​(Message message)
      The given message has just been forcibly removed from the queue, i.e.
      void messageSent​(Message message)
      The given message has been completely sent out through the transport.
      void protocolBytesSent​(int byte_count)
      The given number of protocol (overhead) bytes has been written to the transport.
    • Method Detail

      • messageAdded

        boolean messageAdded​(Message message)
        The given message has just been added to the queue.
        Parameters:
        message - added for queuing
        Returns:
        true if this message addition is allowed, false if it should be immediately removed without being queued or sent
      • messageQueued

        void messageQueued​(Message message)
        The given message has just been queued for sending out the transport.
        Parameters:
        message - queued
      • messageRemoved

        void messageRemoved​(Message message)
        The given message has just been forcibly removed from the queue, i.e. it was *not* sent out the transport.
        Parameters:
        message - removed
      • messageSent

        void messageSent​(Message message)
        The given message has been completely sent out through the transport.
        Parameters:
        message - sent
      • protocolBytesSent

        void protocolBytesSent​(int byte_count)
        The given number of protocol (overhead) bytes has been written to the transport.
        Parameters:
        byte_count - number of protocol bytes
      • dataBytesSent

        void dataBytesSent​(int byte_count)
        The given number of (piece) data bytes has been written to the transport.
        Parameters:
        byte_count - number of data bytes
      • flush

        void flush()