Skip to content

Commit db71e27

Browse files
author
Emile Joubert
committed
Merged bug24835 into default
2 parents fd15684 + ccaeca7 commit db71e27

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)