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 95a7ba6927..ee60a1481e 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
@@ -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) {