Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ service overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---

org.activemq.service
Interface Dispatcher  

All Superinterfaces:

Service

---

public interface Dispatcher

extends Service

A dispatcher of messages to some JMS connection.

Typically this uses either IO or NIO to shovel the messages down a socket as fast as possible - in either a push or pull way.

Version:

$Revision: 1.1.1.1 $

---

Method Summary
void	addActiveSubscription(org.activemq.broker.BrokerClient client, Subscription sub)           Add an active subscription
void	register(MessageContainerManager mcm)           Register the MessageContainerManager for the Dispatcher
void	removeActiveSubscription(org.activemq.broker.BrokerClient client, Subscription sub)           remove an active subscription
void	wakeup()           Called to indicate that there is work to do this will wake up a Dispatch Worker if it is waiting for messages to dispatch
void	wakeup(Subscription sub)           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 interface org.activemq.service.Service

start, stop

 

Method Detail

register

public void register(MessageContainerManager mcm)

Register the MessageContainerManager for the Dispatcher

---

wakeup

public void wakeup(Subscription sub)

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

---

wakeup

public void wakeup()

Called to indicate that there is work to do this will wake up a Dispatch Worker if it is waiting for messages to dispatch

---

addActiveSubscription

public void addActiveSubscription(org.activemq.broker.BrokerClient client,
                                  Subscription sub)

Add an active subscription

---

removeActiveSubscription

public void removeActiveSubscription(org.activemq.broker.BrokerClient client,
                                     Subscription sub)

remove an active subscription

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ service overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---