Skip to content

Commit 54d75b7

Browse files
author
Tim Watson
committed
merge heads
2 parents 5bdfd30 + 47b44d3 commit 54d75b7

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/rabbit_channel.erl

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1085,8 +1085,9 @@ handle_method(#'tx.commit'{}, _, #ch{tx = none}) ->
10851085
handle_method(#'tx.commit'{}, _, State = #ch{tx = {Msgs, Acks},
10861086
limiter = Limiter}) ->
10871087
State1 = rabbit_misc:queue_fold(fun deliver_to_queues/2, State, Msgs),
1088-
lists:foreach(fun ({ack, A}) -> ack(A, State1);
1089-
({Requeue, A}) -> reject(Requeue, A, Limiter)
1088+
Rev = fun (X) -> lists:reverse(lists:sort(X)) end,
1089+
lists:foreach(fun ({ack, A}) -> ack(Rev(A), State1);
1090+
({Requeue, A}) -> reject(Requeue, Rev(A), Limiter)
10901091
end, lists:reverse(Acks)),
10911092
{noreply, maybe_complete_tx(State1#ch{tx = committing})};
10921093

0 commit comments

Comments
 (0)