diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-22 15:47:13 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-03-22 15:47:13 +0000 |
| commit | 0b039a983d28cc0aed2a47e0eb470a91fdcc424b (patch) | |
| tree | da137db2b45c9d579445bdefcd3b89caf63168b6 /src | |
| parent | 377269f581c42b7d84c76303be0e026686cee75e (diff) | |
| download | rabbitmq-server-git-0b039a983d28cc0aed2a47e0eb470a91fdcc424b.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index bb6636eb80..cac622f856 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1411,11 +1411,10 @@ process_routing_result(routed, QPids, XName, MsgSeqNo, _, State) -> send_nacks([], State) -> State; send_nacks(MXs, State = #ch{tx_status = none}) -> - MsgSeqNos = [ MsgSeqNo || {MsgSeqNo, _} <- MXs ], - coalesce_and_send(MsgSeqNos, + coalesce_and_send([MsgSeqNo || {MsgSeqNo, _} <- MXs], fun(MsgSeqNo, Multiple) -> #'basic.nack'{delivery_tag = MsgSeqNo, - multiple = Multiple} + multiple = Multiple} end, State); send_nacks(_, State) -> maybe_complete_tx(State#ch{tx_status = failed}). |