diff options
| -rw-r--r-- | src/rabbit_channel.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 1c08ad6d3b..1285064f43 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -873,9 +873,9 @@ internal_rollback(State = #ch{transaction_id = TxnKey, end. rollback_and_notify(State = #ch{transaction_id = none}) -> - notify_queues(internal_rollback(State)); + notify_queues(State); rollback_and_notify(State) -> - notify_queues(State). + notify_queues(internal_rollback(State)). fold_per_queue(F, Acc0, UAQ) -> D = lists:foldl( |