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

ARTEMIS-2457 fix non-destructive ring q test

This commit is contained in:
Justin Bertram 2019-08-26 08:30:49 -05:00 committed by Clebert Suconic
parent 34e2f40c1c
commit dde6862aed
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3514,12 +3514,9 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
queue.decDelivering(ref); queue.decDelivering(ref);
if (nonDestructive && reason == AckReason.NORMAL) { if (nonDestructive && reason == AckReason.NORMAL) {
return; // this is done to tell the difference between actual acks and just a closed consumer in the non-destructive use-case
}
// this is done to tell the difference between actual acks and just a closed consumer in the non-destructive use-case
if (nonDestructive && reason == AckReason.NORMAL) {
ref.setInDelivery(false); ref.setInDelivery(false);
return;
} }
if (reason == AckReason.EXPIRED) { if (reason == AckReason.EXPIRED) {