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()