org.apache.activemq.broker.region
Class QueueDispatchSelector

java.lang.Object
  extended by org.apache.activemq.broker.region.policy.SimpleDispatchSelector
      extended by 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$

Constructor Summary
QueueDispatchSelector(ActiveMQDestination destination)
           
 
Method Summary
protected  void assignGroup(Subscription subs, MessageGroupMap messageGroupOwners, MessageReference n, String groupId)
           
 boolean canSelect(Subscription subscription, MessageReference m)
           
 Subscription getExclusiveConsumer()
           
 boolean isExclusiveConsumer(Subscription s)
           
 void setExclusiveConsumer(Subscription exclusiveConsumer)
           
 
Methods inherited from class org.apache.activemq.broker.region.policy.SimpleDispatchSelector
canDispatch
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

QueueDispatchSelector

public QueueDispatchSelector(ActiveMQDestination destination)
Parameters:
destination -
Method Detail

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.