Interface IncomingMessageQueue.MessageQueueListener

  • Enclosing interface:
    IncomingMessageQueue

    public static interface IncomingMessageQueue.MessageQueueListener
    For notification of queue events.
    • Method Detail

      • messageReceived

        boolean messageReceived​(Message message)
                         throws java.io.IOException
        A message has been read from the connection.
        Parameters:
        message - recevied
        Returns:
        true if this message was accepted, false if not handled
        Throws:
        java.io.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()