diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-07 11:58:54 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-07 11:58:54 +0000 |
| commit | 644d87ace4fd2e1f1f80925492d4d34fd35058ea (patch) | |
| tree | db9e9c0748ce0383bf64d6a9354b83b2025c397e | |
| parent | de1715d5cc4dcf903d160061d6005b49aba1014e (diff) | |
| download | rabbitmq-server-git-644d87ace4fd2e1f1f80925492d4d34fd35058ea.tar.gz | |
oops
| -rw-r--r-- | src/rabbit_channel.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index df056a6e31..88e3dfc583 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1032,10 +1032,9 @@ handle_method(#'tx.commit'{}, _, #ch{tx = none}) -> handle_method(#'tx.commit'{}, _, State = #ch{tx = {Msgs, Acks}, limiter = Limiter}) -> State1 = rabbit_misc:queue_fold(fun deliver_to_queues/2, State, Msgs), - lists:foreach( - fun ({ack, A}) -> ack(lists:reverse(A), State1); - ({Requeue, A}) -> reject(Requeue, lists:reverse(A), Limiter) - end, lists:reverse(Acks)), + lists:foreach(fun ({ack, A}) -> ack(A, State1); + ({Requeue, A}) -> reject(Requeue, A, Limiter) + end, lists:reverse(Acks)), {noreply, maybe_complete_tx(State1#ch{tx = committing})}; handle_method(#'tx.rollback'{}, _, #ch{tx = none}) -> |
