diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2019-11-29 09:19:28 +0000 |
|---|---|---|
| committer | dcorbacho <dparracorbacho@piotal.io> | 2019-11-29 09:19:28 +0000 |
| commit | 222b254121a1325f6b14f1c5e249c00c9477fe25 (patch) | |
| tree | bbd801cde656feee53d80b180d2c938de5a413ac /test | |
| parent | 0fee9afc0832edd21915cfa69ab9b010307a5395 (diff) | |
| download | rabbitmq-server-git-222b254121a1325f6b14f1c5e249c00c9477fe25.tar.gz | |
Take consumers from `handle_tick` arguments, as stats from `infos` are not yet updated
Diffstat (limited to 'test')
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index ed08675f1f..0894c1fb17 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -2246,7 +2246,7 @@ in_memory(Config) -> dirty_query([Server], RaName, fun rabbit_fifo:query_in_memory_usage/1)). consumer_metrics(Config) -> - [Server | _] = Servers = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), + [Server | _] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), Ch1 = rabbit_ct_client_helpers:open_channel(Config, Server), QQ = ?config(queue_name, Config), @@ -2259,9 +2259,9 @@ consumer_metrics(Config) -> timer:sleep(5000), QNameRes = rabbit_misc:r(<<"/">>, queue, QQ), [{_, PropList, _}] = rpc:call(Leader, ets, lookup, [queue_metrics, QNameRes]), - ?assertMatch([_], lists:filter(fun({Key, _}) -> - Key == consumers - end, PropList)). + ?assertMatch([{consumers, 1}], lists:filter(fun({Key, _}) -> + Key == consumers + end, PropList)). %%---------------------------------------------------------------------------- |