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 | 159d9da835ab6b6c3cc4c0223663a1473186ff27 (patch) | |
| tree | bab351290236713d0acc3c2863ac0142a9711db4 | |
| parent | bd02c71a2091d3d885ea0b74d120cb4b274b748b (diff) | |
| download | rabbitmq-server-git-159d9da835ab6b6c3cc4c0223663a1473186ff27.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 678926af89..c5f83c24dc 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) -> |