Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #2375

This commit is contained in:
Michael Andre Pearce 2018-10-29 20:40:51 +00:00
parent a78ed9a2b3 b0d36ebc50
commit 0630a18135
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
View File

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