Interface IncomingMessageQueue.MessageQueueListener

Enclosing interface:
IncomingMessageQueue
public static interface IncomingMessageQueue.MessageQueueListener
For notification of queue events.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    dataBytesReceived(long byte_count)
    The given number of (piece) data bytes read from the connection.
    boolean
    isPriority()
     
    boolean
    messageReceived(Message message)
    A message has been read from the connection.
    void
    protocolBytesReceived(long byte_count)
    The given number of protocol (overhead) bytes read from the connection.

  • Method Details

    • messageReceived

      boolean messageReceived(Message message) throws IOException
      A message has been read from the connection.
      Parameters:
      message - received
      Returns:
      true if this message was accepted, false if not handled
      Throws:
      IOException

    • protocolBytesReceived

      void protocolBytesReceived(long byte_count)
      The given number of protocol (overhead) bytes read from the connection.
      Parameters:
      byte_count - number of protocol bytes

    • dataBytesReceived

      void dataBytesReceived(long byte_count)
      The given number of (piece) data bytes read from the connection.
      Parameters:
      byte_count - number of data bytes

    • isPriority

      boolean isPriority()