summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJean-Sébastien Pédron <jean-sebastien@rabbitmq.com>2017-07-12 11:27:24 +0200
committerJean-Sébastien Pédron <jean-sebastien@rabbitmq.com>2017-07-12 11:27:24 +0200
commit1532037fec1291641d55f460046070902081b5e3 (patch)
tree6e09727955cdb839fa89a7d3ff8471794de148e0
parentc7c3f921163f539dc30758f1ef1bd67e8a473144 (diff)
downloadrabbitmq-server-git-1532037fec1291641d55f460046070902081b5e3.tar.gz
rabbit_core_metrics_gc_SUITE: Wait for condition in a loop
This hopefully further improves commit 6f374fb48a5cc9972ce0bfcf747faa380e1d1e4d.
-rw-r--r--test/rabbit_core_metrics_gc_SUITE.erl13
1 files changed, 9 insertions, 4 deletions
diff --git a/test/rabbit_core_metrics_gc_SUITE.erl b/test/rabbit_core_metrics_gc_SUITE.erl
index 8d15afb95c..47d47290a4 100644
--- a/test/rabbit_core_metrics_gc_SUITE.erl
+++ b/test/rabbit_core_metrics_gc_SUITE.erl
@@ -377,10 +377,15 @@ cluster_queue_metrics(Config) ->
[queue_coarse_metrics])
end, 60),
-
- [{Name, 1, 0, 1, _}] = rabbit_ct_broker_helpers:rpc(Config, Node1, ets,
- tab2list,
- [queue_coarse_metrics]),
+ wait_for(fun () ->
+ Ret = rabbit_ct_broker_helpers:rpc(
+ Config, Node1, ets, tab2list,
+ [queue_coarse_metrics]),
+ case Ret of
+ [{Name, 1, 0, 1, _}] -> true;
+ _ -> false
+ end
+ end, 60),
amqp_channel:call(Ch, #'queue.delete'{queue=QueueName}),
rabbit_ct_client_helpers:close_channel(Ch),