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(int byte_count)
    The given number of (piece) data bytes read from the connection.
    boolean
     
    boolean
    A message has been read from the connection.
    void
    protocolBytesReceived(int 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(int byte_count)
      The given number of protocol (overhead) bytes read from the connection.
      Parameters:
      byte_count - number of protocol bytes
    • dataBytesReceived

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

      boolean isPriority()