summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <mklishin@pivotal.io>2020-04-10 18:50:34 +0300
committerGitHub <noreply@github.com>2020-04-10 18:50:34 +0300
commit3dd73b21acf3664093f4434ca4dff7bda283cce1 (patch)
tree2bcb3178cf1d3e8ab56534afd97fe1edd681ea6c
parentbe144f487c2eb69df0e6c39a58e3ce0adb8d8a26 (diff)
parentae07ff2892892068bda8abc996f7b4d2150fdf3f (diff)
downloadrabbitmq-server-git-3dd73b21acf3664093f4434ca4dff7bda283cce1.tar.gz
Merge pull request #2310 from rabbitmq/t-list-queues-online-and-offline
Wait until node detects new cluster configuration
-rw-r--r--test/list_queues_online_and_offline_SUITE.erl5
1 files changed, 5 insertions, 0 deletions
diff --git a/test/list_queues_online_and_offline_SUITE.erl b/test/list_queues_online_and_offline_SUITE.erl
index 5985901e75..bb799f64dd 100644
--- a/test/list_queues_online_and_offline_SUITE.erl
+++ b/test/list_queues_online_and_offline_SUITE.erl
@@ -85,6 +85,11 @@ list_queues_online_and_offline(Config) ->
rabbit_ct_broker_helpers:rabbitmqctl(Config, B, ["stop"]),
+ rabbit_ct_helpers:await_condition(
+ fun() ->
+ [A] == rpc:call(A, rabbit_mnesia, cluster_nodes, [running])
+ end, 60000),
+
GotUp = lists:sort(rabbit_ct_broker_helpers:rabbitmqctl_list(Config, A,
["list_queues", "--online", "name", "--no-table-headers"])),
ExpectUp = [[<<"q_a_1">>], [<<"q_a_2">>]],