ARTEMIS-289 potential ConcurrentModificationException

2015-10-29 13:41:08 -05:00 · 2015-10-29 13:41:08 -05:00 · 43b421a588
parent 8aaed7568b
commit 43b421a588
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
@ -791,7 +791,7 @@ public class QueueImpl implements Queue {
   }

   public synchronized Set<Consumer> getConsumers() {
-      return consumerSet;
+      return new HashSet<Consumer>(consumerSet);
   }

   public boolean hasMatchingConsumer(final ServerMessage message) {