Skip to content

Commit 417a2d9

Browse files
ansdkjnilsson
authored andcommitted
Redeliver all pending consumer messages in correct order
1 parent 235bd37 commit 417a2d9

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

deps/rabbit/src/rabbit_fifo.erl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -744,7 +744,8 @@ snapshot_installed(_Meta, #?MODULE{cfg = #cfg{},
744744
Acc) ->
745745
case node(Pid) == node() of
746746
true ->
747-
Acc#{{Tag, Pid} => maps:to_list(Checked)};
747+
Iter = maps:iterator(Checked, ordered),
748+
Acc#{{Tag, Pid} => maps:to_list(Iter)};
748749
false ->
749750
Acc
750751
end

0 commit comments

Comments
 (0)