Skip to content

Commit ccaeca7

Browse files
author
Steve Powell
committed
Correct call to handleAckNack on receiving a NACK.
1 parent fd15684 commit ccaeca7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/com/rabbitmq/client/impl/ChannelN.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -354,7 +354,7 @@ private void releaseChannel() {
354354
} else if (method instanceof Basic.Nack) {
355355
Basic.Nack nack = (Basic.Nack) method;
356356
callConfirmListeners(command, nack);
357-
handleAckNack(nack.getDeliveryTag(), nack.getMultiple(), false);
357+
handleAckNack(nack.getDeliveryTag(), nack.getMultiple(), true);
358358
return true;
359359
} else if (method instanceof Basic.RecoverOk) {
360360
for (Map.Entry<String, Consumer> entry : _consumers.entrySet()) {

0 commit comments

Comments
 (0)