Class PriorityDispatchPolicy
- java.lang.Object
-
- org.apache.activemq.broker.region.policy.SimpleDispatchPolicy
-
- 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
Constructors Constructor Description PriorityDispatchPolicy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers)
Decides how to dispatch a selected message to a collection of consumers.
-
-
-
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 interfaceDispatchPolicy
- Overrides:
dispatch
in classSimpleDispatchPolicy
- Returns:
- true if at least one consumer was dispatched or false if there are no active subscriptions that could be dispatched
- Throws:
Exception
-
-