Interface IncomingMessageQueue

    • Method Detail

      • 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 java.io.IOException
        Notifty the queue (and its listeners) of a message received externally on the queue's behalf.
        Parameters:
        message - received externally
        Throws:
        java.io.IOException
      • getPercentDoneOfCurrentMessage

        int getPercentDoneOfCurrentMessage()