Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-23 10:52:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

This closes #2665

Browse Source
This commit is contained in:
Clebert Suconic 2019-05-10 12:51:32 -04:00
commit 0ffe1ab0a4
1 changed files with 4 additions and 0 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

@ -2599,6 +2599,10 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
if (status == HandleStatus.HANDLED) {
// if a message was delivered, any previous negative attemps need to be cleared
// this is to avoid breaks on the loop when checking for any other factors.
noDelivery = 0;
if (redistributor == null) {
ref = handleMessageGroup(ref, consumer, groupConsumer, groupID);
}