ARTEMIS-2335 Fixing delivery logic for message group on negative attemps

OpenWireGroupingTest::testGrouping is fixed after this change as it was intermittently failing
This commit is contained in:
Clebert Suconic 2019-05-10 11:49:28 -04:00
parent 389edd4976
commit fc760265a2
1 changed files with 4 additions and 0 deletions

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);
}