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 | f363874972e9c7908d58daaf9deb426414107a5c (patch) | |
| tree | 420b5d2c8cd294158f616e972146067334c4515e | |
| parent | 9dc88ef9363f55f11f5ada3b9a4918b2c36cabaa (diff) | |
| download | rabbitmq-server-bug21583.tar.gz | |
oopsbug21583
| -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 1c08ad6d..1285064f 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( |