activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-artemis git commit: fixing filter in retry message
Date Wed, 13 Jan 2016 19:02:58 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master 4bc3422f6 -> 4bd0be40e


fixing filter in retry message


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/79454893
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/79454893
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/79454893

Branch: refs/heads/master
Commit: 79454893cea673210f8b5fa8ab7c2bb8937746e1
Parents: 4bc3422
Author: Andy Taylor <andy.tayls67@gmail.com>
Authored: Wed Jan 13 18:47:59 2016 +0000
Committer: Andy Taylor <andy.tayls67@gmail.com>
Committed: Wed Jan 13 18:48:29 2016 +0000

----------------------------------------------------------------------
 .../org/apache/activemq/artemis/core/server/impl/QueueImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/79454893/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
----------------------------------------------------------------------
diff --git 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
index 6f3cc6f..866ea85 100644
--- 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 {
 


Mime
View raw message