org.apache.activemq.broker.region.policy
Class PriorityDispatchPolicy

java.lang.Object
  extended by org.apache.activemq.broker.region.policy.SimpleDispatchPolicy
      extended by org.apache.activemq.broker.region.policy.PriorityDispatchPolicy
All Implemented Interfaces:
DispatchPolicy

public class PriorityDispatchPolicy
extends SimpleDispatchPolicy

Priority dispatch policy that sends a message to every subscription that matches the message in consumer priority order.


Constructor Summary
PriorityDispatchPolicy()
           
 
Method Summary
 boolean dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
          Decides how to dispatch a selected message to a collection of consumers.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PriorityDispatchPolicy

public PriorityDispatchPolicy()
Method Detail

dispatch

public boolean dispatch(MessageReference node,
                        MessageEvaluationContext msgContext,
                        List<Subscription> consumers)
                 throws Exception
Description copied from interface: DispatchPolicy
Decides how to dispatch a selected message to a collection of consumers. A safe approach is to dispatch to every subscription that matches. The list will be safe to iterate over when this method is called

Specified by:
dispatch in interface DispatchPolicy
Overrides:
dispatch in class SimpleDispatchPolicy
Returns:
true if at least one consumer was dispatched or false if there are no active subscriptions that could be dispatched
Throws:
Exception


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.