Skip to content

Commit ae28808

Browse files
committed
Fix flaky test
1 parent 05f436c commit ae28808

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

deps/rabbitmq_management/test/clustering_SUITE.erl

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -214,7 +214,7 @@ queue_on_other_node(Config) ->
214214
Conn = rabbit_ct_client_helpers:open_unmanaged_connection(Config, 1),
215215
{ok, Chan} = amqp_connection:open_channel(Conn),
216216
_ = queue_declare(Chan, <<"some-queue">>),
217-
_ = wait_for_queue(Config, "/queues/%2F/some-queue"),
217+
eventually(?_assertEqual(1, length(http_get(Config, "/queues/%2F"))), 2000, 5),
218218

219219
{ok, Chan2} = amqp_connection:open_channel(?config(conn, Config)),
220220
consume(Chan2, <<"some-queue">>),
@@ -899,7 +899,6 @@ wait_for_queue(Config, Path, Keys) ->
899899

900900
wait_for_queue(_Config, Path, Keys, 0) ->
901901
exit({timeout, {Path, Keys}});
902-
903902
wait_for_queue(Config, Path, Keys, Count) ->
904903
Res = http_get(Config, Path),
905904
case present(Keys, Res) of

0 commit comments

Comments
 (0)