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

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 java.lang.Exception

Throws:

java.lang.Exception