org.apache.activemq.broker.region.policy
Interface DispatchPolicy
- All Known Implementing Classes:
- PriorityNetworkDispatchPolicy, RoundRobinDispatchPolicy, SimpleDispatchPolicy, StrictOrderDispatchPolicy
public interface DispatchPolicy
Abstraction to allow different dispatching policies to be plugged
into the topic region implementations. This is used by a topic to deliver
messages to the matching subscriptions.
dispatch
boolean dispatch(MessageReference node,
MessageEvaluationContext msgContext,
java.util.List<Subscription> consumers)
throws java.lang.Exception
- 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
- Returns:
- true if at least one consumer was dispatched or false if there are no active subscriptions that could be dispatched
- Throws:
java.lang.Exception
Copyright © 2005-2016. All Rights Reserved.