This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch activemq-5.18.x
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/activemq-5.18.x by this push:
     new 2383a06b20 [AMQ-9233] Prevent NPE in SubQueueSelectorCacheBroker
2383a06b20 is described below

commit 2383a06b20c4d32f2ac44271c91f7deb80bfc38c
Author: Jean-Baptiste Onofré <jbono...@apache.org>
AuthorDate: Wed Jun 21 07:38:36 2023 +0200

    [AMQ-9233] Prevent NPE in SubQueueSelectorCacheBroker
    
    (cherry picked from commit 95e3c2a1aa0d4962ad6a22a4422a9314875f824b)
---
 .../java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java
 
b/activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java
index 322e1e7126..50cdaf3550 100644
--- 
a/activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java
+++ 
b/activemq-broker/src/main/java/org/apache/activemq/plugin/SubQueueSelectorCacheBroker.java
@@ -180,7 +180,7 @@ public class SubQueueSelectorCacheBroker extends 
BrokerFilter implements Runnabl
             if (singleSelectorPerDestination) {
                 String destinationName = 
info.getDestination().getQualifiedName();
                 Set<String> selectors = subSelectorCache.get(destinationName);
-                if (info.getSelector() == null && selectors.size() > 1) {
+                if (info.getSelector() == null && (selectors != null && 
selectors.size() > 1)) {
                     boolean removed = selectors.remove(MATCH_EVERYTHING);
                     LOG.debug("A non-selector consumer has dropped. Removing 
the catchall matching pattern 'TRUE'. Successful? " + removed);
                 }

Reply via email to