Skip to content

Commit

Permalink
Simplify publish_confirm_many
Browse files Browse the repository at this point in the history
  • Loading branch information
LoisSotoLopez committed Oct 24, 2024
1 parent 42b58c7 commit 3b5069f
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions deps/rabbit/test/quorum_queue_SUITE.erl
Original file line number Diff line number Diff line change
Expand Up @@ -4495,12 +4495,7 @@ lists_interleave([Item | Items], List)
Left ++ [Item | lists_interleave(Items, Right)].

publish_confirm_many(Ch, Queue, Count) ->
lists:foldl(fun(_, {Oks, Fails}) ->
case publish_confirm(Ch, Queue) of
ok -> {Oks + 1, Fails};
_ -> {Oks, Fails + 1}
end
end, {0,0}, lists:seq(1, Count)).
lists:foreach(fun(_) -> publish_confirm(Ch, Queue) end, lists:seq(1, Count)).

consume_all(Ch, QQ) ->
Consume = fun C(Acc) ->
Expand Down

0 comments on commit 3b5069f

Please sign in to comment.