public class QueueDispatchSelector extends SimpleDispatchSelector
Constructor and Description |
---|
QueueDispatchSelector(ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
boolean |
canSelect(Subscription subscription,
MessageReference m) |
Subscription |
getExclusiveConsumer() |
boolean |
isExclusiveConsumer(Subscription s) |
boolean |
isPaused() |
void |
pause() |
void |
resume() |
void |
setExclusiveConsumer(Subscription exclusiveConsumer) |
canDispatch
public QueueDispatchSelector(ActiveMQDestination destination)
destination
- public Subscription getExclusiveConsumer()
public void setExclusiveConsumer(Subscription exclusiveConsumer)
public boolean isExclusiveConsumer(Subscription s)
public boolean canSelect(Subscription subscription, MessageReference m) throws Exception
Exception
public void pause()
public void resume()
public boolean isPaused()
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.