public class SubQueueSelectorCacheBroker extends BrokerFilter implements 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,
File persistFile)
Constructor
|
Modifier and Type | Method and Description |
---|---|
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer.
|
String |
getSelector(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 void stop() throws Exception
stop
in interface Service
stop
in class BrokerFilter
Exception
public Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic String getSelector(String destination)
destination
public void run()
MAX_PERSIST_INTERVAL
ms.run
in interface Runnable
Runnable.run()
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.