From 1e9a95c3eb65d58b2d4ce291025804ddea61e1a8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Arnaud=20Cogolu=C3=A8gnes?= Date: Thu, 24 Jan 2019 10:52:14 +0100 Subject: Add activity status to consumer metrics [#163298456] References rabbitmq/rabbitmq-server#1838 --- deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'deps/rabbitmq_management_agent') diff --git a/deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl b/deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl index ecf68351de..372434a5b7 100644 --- a/deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl +++ b/deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl @@ -403,7 +403,8 @@ aggregate_entry({Id, Reductions}, NextStats, Ops0, Ops = insert_entry_ops(channel_process_stats, Id, false, Entry, Ops0, BPolicies), {NextStats, Ops, State}; -aggregate_entry({Id, Exclusive, AckRequired, PrefetchCount, Active, Args}, +aggregate_entry({Id, Exclusive, AckRequired, PrefetchCount, + Active, ActivityStatus, Args}, NextStats, Ops0, #state{table = consumer_created} = State) -> case ets:lookup(consumer_stats, Id) of @@ -412,6 +413,7 @@ aggregate_entry({Id, Exclusive, AckRequired, PrefetchCount, Active, Args}, {ack_required, AckRequired}, {prefetch_count, PrefetchCount}, {active, Active}, + {activity_status, ActivityStatus}, {arguments, Args}], {[], false}), Entry = ?consumer_stats(Id, Fmt), Ops = insert_with_index_op(consumer_stats, Id, Entry, Ops0), @@ -424,6 +426,7 @@ aggregate_entry({Id, Exclusive, AckRequired, PrefetchCount, Active, Args}, {ack_required, AckRequired}, {prefetch_count, PrefetchCount}, {active, Active}, + {activity_status, ActivityStatus}, {arguments, Args}], {[], false}), Entry = ?consumer_stats(Id, Fmt), Ops = insert_with_index_op(consumer_stats, Id, Entry, Ops0), -- cgit v1.2.1