org.apache.activemq.broker.region
Class QueueDispatchSelector
java.lang.Object
org.apache.activemq.broker.region.policy.SimpleDispatchSelector
org.apache.activemq.broker.region.QueueDispatchSelector
- All Implemented Interfaces:
- DispatchSelector
public class QueueDispatchSelector
- extends SimpleDispatchSelector
Queue dispatch policy that determines if a message can be sent to a subscription
- Version:
- $Revision$
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
QueueDispatchSelector
public QueueDispatchSelector(ActiveMQDestination destination)
- Parameters:
destination
-
getExclusiveConsumer
public Subscription getExclusiveConsumer()
setExclusiveConsumer
public void setExclusiveConsumer(Subscription exclusiveConsumer)
isExclusiveConsumer
public boolean isExclusiveConsumer(Subscription s)
canSelect
public boolean canSelect(Subscription subscription,
MessageReference m)
throws Exception
- Throws:
Exception
assignGroup
protected void assignGroup(Subscription subs,
MessageGroupMap messageGroupOwners,
MessageReference n,
String groupId)
throws IOException
- Throws:
IOException
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.