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

ARTEMIS-2650 OpenWire Browsing is not sending credits

This commit is contained in:
Clebert Suconic 2020-03-16 09:09:33 -04:00
parent 4d2b6c07bd
commit d15b3aeed6
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/amq/AMQConsumer.java
View File

@ -304,7 +304,7 @@ public class AMQConsumer {
List<MessageReference> ackList = serverConsumer.getDeliveringReferencesBasedOnProtocol(removeReferences, first, last);
if (ack.isIndividualAck() || ack.isStandardAck() || ack.isPoisonAck()) {
if (removeReferences && (ack.isIndividualAck() || ack.isStandardAck() || ack.isPoisonAck())) {
acquireCredit(ackList.size());
} else {
acquireCredit(ack.getMessageCount());