Skip to content

Commit 655f1a6

Browse files
Merge pull request #12373 from rabbitmq/cloudamqp-prevent-duplicate-vhost-label-on-queue-exchange-metrics
Prevent duplicate vhost label on queue exchange metrics
2 parents e110377 + 79083a4 commit 655f1a6

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

deps/rabbitmq_prometheus/src/collectors/prometheus_rabbitmq_core_metrics_collector.erl

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -489,6 +489,14 @@ label({RemoteAddress, Username, Protocol}) when is_binary(RemoteAddress), is_bin
489489
V =/= <<>>
490490
end, [{remote_address, RemoteAddress}, {username, Username},
491491
{protocol, atom_to_binary(Protocol, utf8)}]);
492+
label({
493+
#resource{kind=queue, virtual_host=VHost, name=QName},
494+
#resource{kind=exchange, name=ExName}
495+
}) ->
496+
%% queue_exchange_metrics {queue_id, exchange_id}
497+
<<"vhost=\"", (escape_label_value(VHost))/binary, "\",",
498+
"exchange=\"", (escape_label_value(ExName))/binary, "\",",
499+
"queue=\"", (escape_label_value(QName))/binary, "\"">>;
492500
label({I1, I2}) ->
493501
case {label(I1), label(I2)} of
494502
{<<>>, L} -> L;

0 commit comments

Comments
 (0)