activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From martyntay...@apache.org
Subject [28/41] activemq-artemis git commit: [ARTEMIS-708] Incorrect ConcurrentHashSet.remove call in QueueImpl.DelayedAddRedistributor.run
Date Fri, 21 Oct 2016 09:56:31 GMT
[ARTEMIS-708] Incorrect ConcurrentHashSet.remove call in QueueImpl.DelayedAddRedistributor.run


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

Branch: refs/heads/ARTEMIS-780
Commit: 028f92ffa5258bb8c9dd7df994b2c75cbd7ecd32
Parents: 813f253
Author: bayern39 <jardenchen@163.com>
Authored: Wed Oct 19 15:53:10 2016 +0800
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Wed Oct 19 15:04:52 2016 -0400

----------------------------------------------------------------------
 .../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/028f92ff/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 5ece228..9e610b2 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
@@ -2709,7 +2709,7 @@ public class QueueImpl implements Queue {
          synchronized (QueueImpl.this) {
             internalAddRedistributor(executor1);
 
-            futures.remove(this);
+            futures.remove(redistributorFuture);
          }
       }
    }


Mime
View raw message