root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Wording

This commit is contained in:
Michael Klishin 2017-01-26 23:19:42 +03:00
parent 53e1d8e776
commit 4e55c07d1a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbitmq_mqtt/test/reader_SUITE.erl vendored
View File

@ -136,14 +136,14 @@ stats(Config) ->
emqttc:publish(C, <<"TopicA">>, <<"Payload">>),
expect_publishes(<<"TopicA">>, [<<"Payload">>]),
emqttc:unsubscribe(C, [<<"TopicA">>]),
timer:sleep(1000), %% Wait for stats to be published, which it does every 100ms
timer:sleep(1000), %% Wait for stats to be emitted, which it does every 100ms
%% Retrieve the connection Pid
[{_, {Reader, _}}] = rpc(Config, rabbit_mqtt_collector, list, []),
[{_, Pid}] = rpc(Config, rabbit_mqtt_reader, info, [Reader, [connection]]),
%% Verify the content of the metrics, garbage_collection must be present
[{Pid, Props}] = rpc(Config, ets, lookup, [connection_metrics, Pid]),
true = proplists:is_defined(garbage_collection, Props),
%% If the coarse entry is present, we have published the data
%% If the coarse entry is present, stats were successfully emitted
[{Pid, _, _, _}] = rpc(Config, ets, lookup, [connection_coarse_metrics, Pid]),
emqttc:disconnect(C).