summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-01-07 11:58:54 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-01-07 11:58:54 +0000
commit259f60e0bbec5388c3834fe18ff49cf82d7cf575 (patch)
treedb9e9c0748ce0383bf64d6a9354b83b2025c397e
parentcebfaf63a18858987bd19b0d2dbfa11642392c69 (diff)
downloadrabbitmq-server-bug25386.tar.gz
-rw-r--r--src/rabbit_channel.erl7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index df056a6e..88e3dfc5 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}) ->