Class SourceMessageProcessor

    • Method Detail

      • getSourceLink

        public SourceLink getSourceLink()
      • processMessages

        public void processMessages​(int numberMessages)
        Description copied from class: MessageProcessor
        Process messages in bulk mode. Called when messages are available and the selector matches, if specified. The queue first obtains the bulk buffer with getBulkBuffer() and fills it with message entries up to the buffer size. It then calls this method and passes the actual number of messages in the buffer. Use this method to store the message and dispatch the MessageProcessor to a thread pool. Implement the processing itself inside the run() method.
        Overrides:
        processMessages in class MessageProcessor
        Parameters:
        numberMessages - number Messages in bulk buffer.
      • 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.
      • getException

        public java.lang.Exception getException()
      • getTransformedMessage

        public Delivery getTransformedMessage()
                                       throws javax.jms.JMSException
        Throws:
        javax.jms.JMSException
      • getTransformedMessages

        public Delivery[] getTransformedMessages()
                                          throws javax.jms.JMSException
        Throws:
        javax.jms.JMSException
      • setStopped

        public void setStopped​(boolean stopped)
      • 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