|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.service.boundedvm.TransientTopicBoundedMessageContainer
A MessageContainer for transient topics One of these exists for every active Connection consuming transient Topic messages
Constructor Summary | |
TransientTopicBoundedMessageContainer(BrokerClient client,
BoundedPacketQueue queue)
Construct this beast |
Method Summary | |
void |
addConsumer(Filter filter,
ConsumerInfo info)
Add a consumer to dispatch messages to |
void |
close()
close down this container |
boolean |
isInactive()
|
void |
removeConsumer(ConsumerInfo info)
Remove a consumer |
void |
run()
do some dispatching |
void |
start()
start working |
void |
stop()
stop working |
boolean |
targetAndDispatch(ActiveMQMessage message)
See if this container should get this message and dispatch it |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public TransientTopicBoundedMessageContainer(BrokerClient client, BoundedPacketQueue queue)
client
- queue
- Method Detail |
public boolean isInactive()
public void addConsumer(Filter filter, ConsumerInfo info)
filter
- info
- public void removeConsumer(ConsumerInfo info)
info
- public void start()
start
in interface Service
public boolean targetAndDispatch(ActiveMQMessage message) throws JMSException
message
-
JMSException
public void stop()
stop
in interface Service
public void close()
public void run()
run
in interface java.lang.Runnable
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |