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


Constructor Summary
QueueDispatchSelector(ActiveMQDestination destination)
           
 
Method Summary
 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


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.