diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-09-07 17:12:53 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-09-07 17:12:53 +0100 |
| commit | 8a3e49ba84425dd57c5693e027378424da0a7706 (patch) | |
| tree | 420b5d2c8cd294158f616e972146067334c4515e /src | |
| parent | 089c379b017ea263fee44a20975eb0d66650be5b (diff) | |
| download | rabbitmq-server-git-8a3e49ba84425dd57c5693e027378424da0a7706.tar.gz | |
oops
Diffstat (limited to 'src')
| -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( |