Package com.swiftmq.impl.queue.standard.cluster

Interface DispatchPolicy

All Known Implementing Classes:
MessageGroupDispatchPolicy, RoundRobinDispatchPolicy
public interface DispatchPolicy

  • Method Details

    • setDispatchPolicyListener

      void setDispatchPolicyListener(DispatchPolicyListener l)

    • addLocalMetric

      void addLocalMetric(QueueMetric metric)

    • removeLocalMetric

      void removeLocalMetric(QueueMetric metric)

    • getLocalMetric

      ClusteredQueueMetric getLocalMetric()

    • addMetric

      void addMetric(String routerName, ClusteredQueueMetric metric)

    • removeMetric

      void removeMetric(String routerName)

    • isReceiverSomewhere

      boolean isReceiverSomewhere()

    • isMessageBasedDispatch

      boolean isMessageBasedDispatch()

    • getNextSendQueue

      String getNextSendQueue()

    • getNextSendQueue

      String getNextSendQueue(MessageImpl message)

    • getNextReceiveQueue

      String getNextReceiveQueue()

    • close

      void close()