[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 <[email protected]> Authored: Wed Oct 19 15:53:10 2016 +0800 Committer: Clebert Suconic <[email protected]> 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); } } }
