diff --git a/deps/rabbitmq_prometheus/src/collectors/prometheus_rabbitmq_core_metrics_collector.erl b/deps/rabbitmq_prometheus/src/collectors/prometheus_rabbitmq_core_metrics_collector.erl index c99f2405564..a474430b599 100644 --- a/deps/rabbitmq_prometheus/src/collectors/prometheus_rabbitmq_core_metrics_collector.erl +++ b/deps/rabbitmq_prometheus/src/collectors/prometheus_rabbitmq_core_metrics_collector.erl @@ -302,6 +302,8 @@ mutually_exclusive_mf(false, auth_attempt_detailed_metrics, _) -> %% `proplists:get_value/2` calls. mutually_exclusive_mf(_, queue_consumer_count, MFs) -> lists:keymember(queue_metrics, 1, MFs); +%%mutually_exclusive_mf(_, rabbit_stream_consumer, MFs) -> +%% lists:keymember(rabbit_stream_consumer_created, 1, MFs); mutually_exclusive_mf(_, _, _) -> false. @@ -535,7 +537,8 @@ get_data(rabbit_stream_publisher_created = Table, false, _, _) -> } end, empty(Table), Table), [{Table, [{published, A1}, {confirmed, A2}, {errored, A3}]}]; - +%%get_data(rabbit_stream_consumer, true, _, _) -> + %% ets:tab2list(rabbit_stream_consumer_created); get_data(rabbit_stream_consumer_created = Table, false, _, _) -> %% Table = rabbit_stream_consumer_created, %% real table name {Table, A1, A2, A3} = ets:foldl(fun({_, Props}, {T, A1, A2, A3}) ->