diff options
Diffstat (limited to 'src')
| -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) -> |