Interface DispatchPolicy
-
- All Known Implementing Classes:
ClientIdFilterDispatchPolicy
,PriorityDispatchPolicy
,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.
-
-
Method Summary
All Methods Instance Methods Abstract 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
boolean dispatch(MessageReference node, MessageEvaluationContext msgContext, List<Subscription> consumers) throws 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:
Exception
-
-