Merge pull request #15432 from rabbitmq/test-flakes-feb10-2026

Test flakes feb10 2026

Author: dcorbacho

deps/rabbitmq_exchange_federation/test/exchange_SUITE.erl

@@ -847,10 +847,17 @@ count_running_links(Config, Server) ->
 %%
 
 clean_up_federation_related_bits(Config) ->
-  delete_all_queues_on(Config, 0),
-  delete_all_exchanges_on(Config, 0),
-  delete_all_policies_on(Config, 0),
-  delete_all_runtime_parameters_on(Config, 0).
+    Nodes = rabbit_ct_broker_helpers:get_node_configs(Config, nodename),
+    [begin
+         delete_all_policies_on(Config, N),
+         delete_all_runtime_parameters_on(Config, N),
+         delete_all_queues_on(Config, N),
+         delete_all_exchanges_on(Config, N)
+     end || N <- lists:seq(0, length(Nodes) - 1)],
+    [rabbit_ct_helpers:await_condition(
+       fun() -> all_queues_on(Config, Node) =:= [] end,
+       30000) || Node <- Nodes],
+    ok.
 
 set_up_upstream(Config) ->
   rabbit_ct_broker_helpers:set_parameter(

deps/rabbitmq_shovel/test/shovel_test_utils.erl

@@ -259,7 +259,7 @@ amqp10_publish_msg(Sender, Tag, Msg) ->
 amqp10_expect_empty(Session, Dest) ->
     LinkName = <<"dynamic-receiver-", Dest/binary>>,
     {ok, Receiver} = amqp10_client:attach_receiver_link(Session, LinkName,
-                                                        Dest, settled,
+                                                        Dest, unsettled,
                                                         unsettled_state),
     ok = amqp10_client:flow_link_credit(Receiver, 1, never),
     receive