diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-01-25 12:33:33 +0000 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-01-25 12:33:33 +0000 |
| commit | efd4e3e9a5c731bc4f7a2141de936c131e630ca0 (patch) | |
| tree | c003ea62e40ec14cac85ecd846ed6ba50ec6cfed | |
| parent | bf2d2db59c75b354d0515f8aebf0c7adbb9afbd4 (diff) | |
| download | rabbitmq-server-git-efd4e3e9a5c731bc4f7a2141de936c131e630ca0.tar.gz | |
Flatten the list of lists.
| -rw-r--r-- | src/rabbit_channel.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 275de0f4bb..474a5a91e6 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1089,7 +1089,7 @@ handle_method(#'tx.rollback'{}, _, #ch{tx_status = none}) -> handle_method(#'tx.rollback'{}, _, State = #ch{unacked_message_q = UAMQ, uncommitted_acks = TAL, uncommitted_nacks = TNL}) -> - TNL1 = lists:map(fun ({_, L}) -> L end, TNL), + TNL1 = lists:append(lists:map(fun ({_, L}) -> L end, TNL)), UAMQ1 = queue:from_list(lists:usort(TAL ++ TNL1 ++ queue:to_list(UAMQ))), {reply, #'tx.rollback_ok'{}, new_tx(State#ch{unacked_message_q = UAMQ1})}; |