Class QueueMessageProcessor

java.lang.Object
com.swiftmq.swiftlet.queue.MessageProcessor
com.swiftmq.impl.streams.processor.QueueMessageProcessor
All Implemented Interfaces:
com.swiftmq.swiftlet.threadpool.AsyncTask, Runnable
public class QueueMessageProcessor extends com.swiftmq.swiftlet.queue.MessageProcessor

  • Constructor Summary

    Constructors
    Constructor
    Description
    QueueMessageProcessor(StreamContext ctx, Input input, com.swiftmq.swiftlet.queue.QueueReceiver receiver, com.swiftmq.swiftlet.queue.Selector selector)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    deregister()
     
    Input
    getInput()
     
    com.swiftmq.jms.MessageImpl
    getMessage()
     
    com.swiftmq.swiftlet.queue.QueuePullTransaction
    getTransaction()
     
    boolean
    isValid()
     
    void
    processException(Exception e)
     
    void
    processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)
     
    void
    restart()
     
    String
    toString()
     

    Methods inherited from class com.swiftmq.swiftlet.queue.MessageProcessor

    createBulkBuffer, getBulkBuffer, getCurrentBulkSize, getDescription, getDispatchToken, getMaxBulkSize, getReceiverId, getRegistrationId, getRegistrationTime, getSelector, getTimeout, getTransactionId, getViewId, isAutoCommit, isBulkMode, processMessages, reset, run, setAutoCommit, setBulkMode, setCurrentBulkSize, setReceiverId, setRegistrationId, setRegistrationTime, setTransactionId, setViewId, stop

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • QueueMessageProcessor

      public QueueMessageProcessor(StreamContext ctx, Input input, com.swiftmq.swiftlet.queue.QueueReceiver receiver, com.swiftmq.swiftlet.queue.Selector selector)

  • Method Details

    • deregister

      public void deregister()

    • restart

      public void restart() throws Exception
      Throws:
      Exception

    • getTransaction

      public com.swiftmq.swiftlet.queue.QueuePullTransaction getTransaction()

    • getInput

      public Input getInput()

    • getMessage

      public com.swiftmq.jms.MessageImpl getMessage()

    • processMessage

      public void processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)
      Specified by:
      processMessage in class com.swiftmq.swiftlet.queue.MessageProcessor

    • processException

      public void processException(Exception e)
      Specified by:
      processException in class com.swiftmq.swiftlet.queue.MessageProcessor

    • isValid

      public boolean isValid()

    • toString

      public String toString()
      Overrides:
      toString in class Object