org.apache.activemq.plugin
public class SubQueueSelectorCacheBroker extends BrokerFilter implements java.lang.Runnable
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
next
Constructor and Description |
---|
SubQueueSelectorCacheBroker(Broker next,
java.io.File persistFile)
Constructor
|
Modifier and Type | Method and Description |
---|---|
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() |
acknowledge, addBroker, addConnection, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start
public SubQueueSelectorCacheBroker(Broker next, java.io.File persistFile)
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()
Copyright © 2005-2014. All Rights Reserved.