diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-11-29 19:39:21 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-11-29 19:39:21 +0300 |
| commit | ab8bb7039619f3e7039c404f00f3bfbb6453aff0 (patch) | |
| tree | 41778abacc2b6ea12aa0d9d3879c8fe9d3e45712 /test | |
| parent | bc392db8a02c347038ef41951f9b0882593ae5d4 (diff) | |
| parent | 222b254121a1325f6b14f1c5e249c00c9477fe25 (diff) | |
| download | rabbitmq-server-git-ab8bb7039619f3e7039c404f00f3bfbb6453aff0.tar.gz | |
Merge pull request #2176 from rabbitmq/duplicated-consumers-metric
Remove duplicated consumers metric in quorum queues
Diffstat (limited to 'test')
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 21 |
1 files changed, 20 insertions, 1 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index aa617ce4bc..0894c1fb17 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -127,7 +127,8 @@ all_tests() -> queue_length_in_memory_bytes_limit_subscribe, queue_length_in_memory_bytes_limit, queue_length_in_memory_purge, - in_memory + in_memory, + consumer_metrics ]. memory_tests() -> @@ -2244,6 +2245,24 @@ in_memory(Config) -> ?assertEqual([{0, 0}], dirty_query([Server], RaName, fun rabbit_fifo:query_in_memory_usage/1)). +consumer_metrics(Config) -> + [Server | _] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), + + Ch1 = rabbit_ct_client_helpers:open_channel(Config, Server), + QQ = ?config(queue_name, Config), + ?assertEqual({'queue.declare_ok', QQ, 0, 0}, + declare(Ch1, QQ, [{<<"x-queue-type">>, longstr, <<"quorum">>}])), + subscribe(Ch1, QQ, false), + + RaName = ra_name(QQ), + {ok, _, {_, Leader}} = ra:members({RaName, Server}), + timer:sleep(5000), + QNameRes = rabbit_misc:r(<<"/">>, queue, QQ), + [{_, PropList, _}] = rpc:call(Leader, ets, lookup, [queue_metrics, QNameRes]), + ?assertMatch([{consumers, 1}], lists:filter(fun({Key, _}) -> + Key == consumers + end, PropList)). + %%---------------------------------------------------------------------------- declare(Ch, Q) -> |