Class QueueMessageProcessor

    • Method Detail

      • deregister

        public void deregister()
      • restart

        public void restart()
                     throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getInput

        public Input getInput()
      • processMessage

        public void processMessage​(MessageEntry messageEntry)
        Description copied from class: MessageProcessor
        Process a message. Called when a message is available and the selector matches, if specified. Use this method to store the message and dispatch the MessageProcessor to a thread pool. Implement the processing itself inside the run() method.
        Specified by:
        processMessage in class MessageProcessor
        Parameters:
        messageEntry - message entry.
      • isValid

        public boolean isValid()
        Description copied from interface: AsyncTask
        Returns whether the task is valid. This is application dependent. As long as a task stays in the thread pool queue, this state can change. If the task is going to execute, it will be checked whether the task is valid. If not, the task isn't executed anymore. For example, if a task depends on a connection and the connection closes before the task is executed, this method should return false which leads to drop the task out of the pool without executing it.
        Returns:
        true/false.
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object