Skip to content

Commit f9d28de

Browse files
committed
exchange federation: test cleanup improvements
Sometimes the queue assertion failed, because the queues from the previous test were still present
1 parent 4add1f3 commit f9d28de

File tree

1 file changed

+11
-4
lines changed

1 file changed

+11
-4
lines changed

deps/rabbitmq_exchange_federation/test/exchange_SUITE.erl

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -847,10 +847,17 @@ count_running_links(Config, Server) ->
847847
%%
848848

849849
clean_up_federation_related_bits(Config) ->
850-
delete_all_queues_on(Config, 0),
851-
delete_all_exchanges_on(Config, 0),
852-
delete_all_policies_on(Config, 0),
853-
delete_all_runtime_parameters_on(Config, 0).
850+
Nodes = rabbit_ct_broker_helpers:get_node_configs(Config, nodename),
851+
[begin
852+
delete_all_policies_on(Config, N),
853+
delete_all_runtime_parameters_on(Config, N),
854+
delete_all_queues_on(Config, N),
855+
delete_all_exchanges_on(Config, N)
856+
end || N <- lists:seq(0, length(Nodes) - 1)],
857+
[rabbit_ct_helpers:await_condition(
858+
fun() -> all_queues_on(Config, Node) =:= [] end,
859+
30000) || Node <- Nodes],
860+
ok.
854861

855862
set_up_upstream(Config) ->
856863
rabbit_ct_broker_helpers:set_parameter(

0 commit comments

Comments
 (0)