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 dfd070fe2e..747db5c6ac 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
@@ -2531,7 +2531,7 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
 
                   removeMessageReference(holder, ref);
 
-                  if (groupID != null && groupConsumer == null) {
+                  if (groupID != null && groupConsumer == null && redistributor == null) {
                      groups.put(groupID, consumer);
                   }
 
@@ -3110,7 +3110,7 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
             HandleStatus status = handle(ref, consumer);
 
             if (status == HandleStatus.HANDLED) {
-               if (groupID != null && groupConsumer == null) {
+               if (groupID != null && groupConsumer == null && redistributor == null) {
                   groups.put(groupID, consumer);
                }