diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2017-07-12 11:27:24 +0200 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2017-07-12 11:27:24 +0200 |
| commit | 1532037fec1291641d55f460046070902081b5e3 (patch) | |
| tree | 6e09727955cdb839fa89a7d3ff8471794de148e0 | |
| parent | c7c3f921163f539dc30758f1ef1bd67e8a473144 (diff) | |
| download | rabbitmq-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.erl | 13 |
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), |
