This closes #1812

2018-01-23 16:14:08 -05:00 · 2018-01-23 16:14:08 -05:00 · dafcbb70a3
parent acd20790f7 98cf8651cf
commit dafcbb70a3
1 changed files with 1 additions and 1 deletions
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/view/predicate/QueueFilterPredicate.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/view/predicate/QueueFilterPredicate.java
@ -53,7 +53,7 @@ public class QueueFilterPredicate extends ActiveMQFilterPredicate<QueueControl>
            case CONSUMER_ID:
               Queue q = server.locateQueue(new SimpleString(queue.getName()));
               for (Consumer consumer : q.getConsumers()) {
-                  if (value.equals(consumer.sequentialID()))
+                  if (matches(consumer.sequentialID()))
                     return true;
               }
               return false;