diff options
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 6625ce4561..9c8cc87570 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1283,8 +1283,9 @@ reject_tx(DeliveryTag, Multiple, Requeue, State1 = State#ch{unacked_message_q = Remaining}, {noreply, case TxStatus of - none -> reject(Requeue, Acked, State1#ch.limiter), - State1; + none -> + reject(Requeue, Acked, State1#ch.limiter), + State1; in_progress -> State1#ch{uncommitted_nacks = {Requeue, Acked} ++ State1#ch.uncommitted_nacks} |