|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.BrokerFilter
org.apache.activemq.plugin.SubQueueSelectorCacheBroker
public class SubQueueSelectorCacheBroker
A plugin which allows the caching of the selector from a subscription queue.
This stops the build-up of unwanted messages, especially when consumers may disconnect from time to time when using virtual destinations. This is influenced by code snippets developed by Maciej Rakowicz
https://issues.apache.org/activemq/browse/AMQ-3004
,
http://mail-archives.apache.org/mod_mbox/activemq-users/201011.mbox/%3C8A013711-2613-450A-A487-379E784AF1D6@homeaway.co.uk%3E
Field Summary |
---|
Fields inherited from class org.apache.activemq.broker.BrokerFilter |
---|
next |
Constructor Summary | |
---|---|
SubQueueSelectorCacheBroker(Broker next,
java.io.File persistFile)
Constructor |
Method Summary | |
---|---|
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer. |
java.lang.String |
getSelector(java.lang.String destination)
|
void |
run()
Persist the selector cache every MAX_PERSIST_INTERVAL ms. |
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public SubQueueSelectorCacheBroker(Broker next, java.io.File persistFile)
Method Detail |
---|
public void stop() throws java.lang.Exception
stop
in interface Service
stop
in class BrokerFilter
java.lang.Exception
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOpublic java.lang.String getSelector(java.lang.String destination)
destination
public void run()
MAX_PERSIST_INTERVAL
ms.
run
in interface java.lang.Runnable
Runnable.run()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |