Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'AMQ-8012' 

This closes #553
This commit is contained in:
Christopher L. Shannon (cshannon) 2020-07-24 14:13:45 -04:00
parent 6c0cb4143d 083acb9691
commit 1dcc7d4b2c
2 changed files with 1 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-broker/src/main/java/org/apache/activemq/broker/region/virtual/SelectorAwareVirtualTopicInterceptor.java
View File

@ -77,7 +77,7 @@ public class SelectorAwareVirtualTopicInterceptor extends VirtualTopicIntercepto
LOG.debug("No active consumer match found. Will try cache if configured..."); LOG.debug("No active consumer match found. Will try cache if configured...");
if (selectorCachePlugin != null) { if (selectorCachePlugin != null) {
final Set<String> selectors = selectorCachePlugin.getSelector(dest.getActiveMQDestination().getQualifiedName()); final Set<String> selectors = selectorCachePlugin.getSelectorsForDestination(dest.getActiveMQDestination().getQualifiedName());
if (selectors != null) { if (selectors != null) {
for (String selector : selectors) { for (String selector : selectors) {
try { try {

7
activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java
View File

@ -248,13 +248,6 @@ public class SubQueueSelectorCacheBroker extends BrokerFilter implements Runnabl
} }
} }
/**
* @return The JMS selector for the specified {@code destination}
*/
public Set<String> getSelector(final String destination) {
return subSelectorCache.get(destination);
}
/** /**
* Persist the selector cache every {@code MAX_PERSIST_INTERVAL}ms. * Persist the selector cache every {@code MAX_PERSIST_INTERVAL}ms.
* *