diff --git a/deps/rabbit/test/rabbitmq_queues_cli_integration_SUITE.erl b/deps/rabbit/test/rabbitmq_queues_cli_integration_SUITE.erl index 8e7243db23..0536f0480e 100644 --- a/deps/rabbit/test/rabbitmq_queues_cli_integration_SUITE.erl +++ b/deps/rabbit/test/rabbitmq_queues_cli_integration_SUITE.erl @@ -77,10 +77,12 @@ shrink(Config) -> publish_confirm(Ch, QName), {ok, Out1} = rabbitmq_queues(Config, 0, ["shrink", Nodename2]), ?assertMatch(#{{"/", "shrink1"} := {2, ok}}, parse_result(Out1)), + timer:sleep(1500), Nodename1 = rabbit_ct_broker_helpers:get_node_config(Config, 1, nodename), publish_confirm(Ch, QName), {ok, Out2} = rabbitmq_queues(Config, 0, ["shrink", Nodename1]), ?assertMatch(#{{"/", "shrink1"} := {1, ok}}, parse_result(Out2)), + timer:sleep(1500), Nodename0 = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename), publish_confirm(Ch, QName), {ok, Out3} = rabbitmq_queues(Config, 0, ["shrink", Nodename0]), @@ -100,6 +102,7 @@ grow(Config) -> publish_confirm(Ch, QName), {ok, Out1} = rabbitmq_queues(Config, 0, ["grow", Nodename0, "all"]), ?assertMatch(#{{"/", "grow1"} := {2, ok}}, parse_result(Out1)), + timer:sleep(500), Nodename1 = rabbit_ct_broker_helpers:get_node_config(Config, 1, nodename), publish_confirm(Ch, QName), {ok, Out2} = rabbitmq_queues(Config, 0, ["grow", Nodename1, "all"]),