fixing filter in retry message

2016-01-13 18:47:59 +00:00 · 2016-01-13 18:47:59 +00:00 · 79454893ce
parent 4bc3422f6a
commit 79454893ce
1 changed files with 1 additions and 1 deletions
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
@ -1604,7 +1604,7 @@ public class QueueImpl implements Queue {

      final HashMap<SimpleString, Long> queues = new HashMap<>();

-      return iterQueue(DEFAULT_FLUSH_LIMIT, null, new QueueIterateAction() {
+      return iterQueue(DEFAULT_FLUSH_LIMIT, filter, new QueueIterateAction() {
         @Override
         public void actMessage(Transaction tx, MessageReference ref) throws Exception {