public class SubQueueSelectorCacheBroker extends BrokerFilter implements Runnable
Modifier and Type | Field and Description |
---|---|
static String |
MATCH_EVERYTHING |
static long |
MAX_PERSIST_INTERVAL |
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.
|
boolean |
deleteAllSelectorsForDestination(String destinationName) |
boolean |
deleteSelectorForDestination(String destinationName,
String selector) |
long |
getPersistInterval() |
Set<String> |
getSelector(String destination) |
Set<String> |
getSelectorsForDestination(String destinationName) |
boolean |
isIgnoreWildcardSelectors() |
boolean |
isSingleSelectorPerDestination() |
void |
removeConsumer(ConnectionContext context,
ConsumerInfo info)
Removes a consumer.
|
void |
run()
Persist the selector cache every
MAX_PERSIST_INTERVAL ms. |
void |
setIgnoreWildcardSelectors(boolean ignoreWildcardSelectors) |
void |
setPersistInterval(long persistInterval) |
void |
setSingleSelectorPerDestination(boolean singleSelectorPerDestination) |
void |
stop() |
acknowledge, addBroker, addConnection, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, 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, reapplyInterceptor, removeBroker, removeConnection, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, virtualDestinationAdded, virtualDestinationRemoved
public static final String MATCH_EVERYTHING
public static final long MAX_PERSIST_INTERVAL
public SubQueueSelectorCacheBroker(Broker next, File persistFile)
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 void removeConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
removeConsumer
in interface Region
removeConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic Set<String> getSelector(String destination)
destination
public void run()
MAX_PERSIST_INTERVAL
ms.run
in interface Runnable
Runnable.run()
public boolean isSingleSelectorPerDestination()
public void setSingleSelectorPerDestination(boolean singleSelectorPerDestination)
public Set<String> getSelectorsForDestination(String destinationName)
public long getPersistInterval()
public void setPersistInterval(long persistInterval)
public boolean deleteSelectorForDestination(String destinationName, String selector)
public boolean deleteAllSelectorsForDestination(String destinationName)
public boolean isIgnoreWildcardSelectors()
public void setIgnoreWildcardSelectors(boolean ignoreWildcardSelectors)
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.