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 #2212

This commit is contained in:
Clebert Suconic 2018-08-03 09:54:41 -04:00
parent 77989c3763 825081cfc0
commit a6ecdcb44f
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

@ -2516,7 +2516,7 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
// Only move onto the next position if the consumer on the current position was used.
// When using group we don't need to load balance to the next position
if (!exclusive && groupConsumer == null) {
if (redistributor == null && !exclusive && groupConsumer == null) {
pos++;
}
@ -3029,7 +3029,7 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
}
// Only move onto the next position if the consumer on the current position was used.
if (!exclusive && groupConsumer == null) {
if (redistributor == null && !exclusive && groupConsumer == null) {
pos++;
}