|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.service.impl.DispatchWorker
A Dispatcher that polls for updates for active Message Consumers
Constructor Summary | |
DispatchWorker()
|
Method Summary | |
void |
addActiveSubscription(BrokerClient client,
Subscription sub)
Add an active subscription |
protected boolean |
dispatchMessages(Subscription subscription,
boolean dispatched)
|
protected void |
doPoll()
|
void |
register(MessageContainerManager mcm)
Register the MessageContainerManager for the Dispatcher |
void |
removeActiveSubscription(BrokerClient client,
Subscription sub)
remove an active subscription |
void |
run()
dispatch messages to active Consumers |
void |
start()
start the DispatchWorker |
void |
stop()
stop the DispatchWorker |
void |
wakeup()
Called to indicate that there is work to do on a Subscription this will wake up a Dispatch Worker if it is waiting for messages to dispatch |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public DispatchWorker()
Method Detail |
public void register(MessageContainerManager mcm)
mcm
- public void wakeup()
public void addActiveSubscription(BrokerClient client, Subscription sub)
client
- sub
- public void removeActiveSubscription(BrokerClient client, Subscription sub)
client
- sub
- public void run()
run
in interface Runnable
Runnable.run()
public void start()
start
in interface Service
Service.start()
public void stop()
stop
in interface Service
Service.stop()
protected boolean dispatchMessages(Subscription subscription, boolean dispatched) throws JMSException
JMSException
protected void doPoll()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |