[ARTEMIS-708] Incorrect ConcurrentHashSet.remove call in QueueImpl.DelayedAddRedistributor.run
This commit is contained in:
parent
813f2532d8
commit
028f92ffa5
|
@ -2709,7 +2709,7 @@ public class QueueImpl implements Queue {
|
|||
synchronized (QueueImpl.this) {
|
||||
internalAddRedistributor(executor1);
|
||||
|
||||
futures.remove(this);
|
||||
futures.remove(redistributorFuture);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue