Interface IncomingMessageQueue

All Known Implementing Classes:
IncomingMessageQueueImpl
public interface IncomingMessageQueue
Inbound message queue.

  • Method Details

    • registerListener

      void registerListener(IncomingMessageQueueListener listener)
      Register queue listener.
      Parameters:
      listener - to register

    • registerPriorityListener

      void registerPriorityListener(IncomingMessageQueueListener listener)
      Register queue listener that will get to process messages *ahead* of the core.
      Parameters:
      listener -

    • deregisterListener

      void deregisterListener(IncomingMessageQueueListener listener)
      Remove registration of queue listener.
      Parameters:
      listener - to remove

    • notifyOfExternalReceive

      void notifyOfExternalReceive(Message message) throws IOException
      Notifty the queue (and its listeners) of a message received externally on the queue's behalf.
      Parameters:
      message - received externally
      Throws:
      IOException

    • getPercentDoneOfCurrentMessage

      default int getPercentDoneOfCurrentMessage()

    • getCurrentMessageProgress

      int[] getCurrentMessageProgress()