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

Constructors

Constructor and Description
QueueDispatchSelector(ActiveMQDestination destination)

Method Summary

Methods

Modifier and Type	Method and Description
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