Skip to content

Commit a819043

Browse files
committed
Report connection/channel/queue churn
Rate metrics for monitoring of high connection churn scenarios [#160943831]
1 parent 3ae27d2 commit a819043

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/rabbit_channel.erl

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2152,6 +2152,7 @@ handle_method(#'queue.declare'{queue = QueueNameBin,
21522152
end,
21532153
QueueName = rabbit_misc:r(VHostPath, queue, ActualNameBin),
21542154
check_configure_permitted(QueueName, User),
2155+
rabbit_core_metrics:queue_declared(QueueName),
21552156
case rabbit_amqqueue:with(
21562157
QueueName,
21572158
fun (Q) -> ok = rabbit_amqqueue:assert_equivalence(
@@ -2189,6 +2190,7 @@ handle_method(#'queue.declare'{queue = QueueNameBin,
21892190
_ -> rabbit_queue_collector:register(
21902191
CollectorPid, QPid)
21912192
end,
2193+
rabbit_core_metrics:queue_created(QueueName),
21922194
{ok, QueueName, 0, 0};
21932195
{existing, _Q} ->
21942196
%% must have been created between the stat and the

0 commit comments

Comments
 (0)