Class TopicJNDIProcessor

java.lang.Object
com.swiftmq.swiftlet.queue.MessageProcessor
com.swiftmq.impl.jndi.standard.TopicJNDIProcessor
All Implemented Interfaces:
com.swiftmq.swiftlet.threadpool.AsyncTask, Runnable
public class TopicJNDIProcessor extends com.swiftmq.swiftlet.queue.MessageProcessor

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    String
    getDescription()
     
    String
    getDispatchToken()
     
    boolean
    isValid()
     
    void
    processException(Exception exception)
     
    void
    processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)
     
    void
    run()
     
    void
    stop()
     

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

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

    Methods inherited from class Object

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

  • Method Details

    • isValid

      public boolean isValid()

    • 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 exception)
      Specified by:
      processException in class com.swiftmq.swiftlet.queue.MessageProcessor

    • getDispatchToken

      public String getDispatchToken()
      Specified by:
      getDispatchToken in interface com.swiftmq.swiftlet.threadpool.AsyncTask
      Overrides:
      getDispatchToken in class com.swiftmq.swiftlet.queue.MessageProcessor

    • getDescription

      public String getDescription()
      Specified by:
      getDescription in interface com.swiftmq.swiftlet.threadpool.AsyncTask
      Overrides:
      getDescription in class com.swiftmq.swiftlet.queue.MessageProcessor

    • stop

      public void stop()
      Specified by:
      stop in interface com.swiftmq.swiftlet.threadpool.AsyncTask
      Overrides:
      stop in class com.swiftmq.swiftlet.queue.MessageProcessor

    • run

      public void run()
      Specified by:
      run in interface com.swiftmq.swiftlet.threadpool.AsyncTask
      Specified by:
      run in interface Runnable
      Overrides:
      run in class com.swiftmq.swiftlet.queue.MessageProcessor

    • close

      public void close()