Class ClusterMetricSubscriber

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    ClusterMetricSubscriber(SwiftletContext ctx)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    boolean
    isValid()
     
    void
    processException(Exception exception)
     
    void
    processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)
     
    void
    run()
     
    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, 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

  • Method Details

    • isValid

      public boolean isValid()

    • processException

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

    • processMessage

      public void processMessage(com.swiftmq.swiftlet.queue.MessageEntry messageEntry)
      Specified by:
      processMessage 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()

    • toString

      public String toString()
      Overrides:
      toString in class Object