diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-05-25 17:01:39 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-05-25 17:01:39 +0100 |
| commit | cf7d7556ceb76ee2bdaa4a31cdd3bef129bac920 (patch) | |
| tree | bab351290236713d0acc3c2863ac0142a9711db4 | |
| parent | 6a8b341e4c4bd6a7f3c08f005416defc20077b91 (diff) | |
| download | rabbitmq-server-cf7d7556ceb76ee2bdaa4a31cdd3bef129bac920.tar.gz | |
Remove R13ism
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 678926af..c5f83c24 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -386,9 +386,8 @@ confirm_messages(MsgIds, State = #state { msg_id_status = MS }) -> Acc end end, {MS, gb_trees:empty()}, MsgIds), - gb_trees:map(fun (ChPid, MsgSeqNos) -> - ok = rabbit_channel:confirm(ChPid, MsgSeqNos) - end, CMs), + [ok = rabbit_channel:confirm(ChPid, MsgSeqNos) + || {ChPid, MsgSeqNos} <- gb_trees:to_list(CMs)], State #state { msg_id_status = MS1 }. gb_trees_cons(Key, Value, Tree) -> |