diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2018-10-08 15:08:03 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2018-10-08 15:08:03 +0100 |
| commit | a819043a31cdea3ff8af37d89ee6bd58a8813d93 (patch) | |
| tree | 669325c922c29acfe11c1ae3964076966d906c2e | |
| parent | 3ae27d2e5a0128c65d1e1312a23ef72103298e9a (diff) | |
| download | rabbitmq-server-git-a819043a31cdea3ff8af37d89ee6bd58a8813d93.tar.gz | |
Report connection/channel/queue churn
Rate metrics for monitoring of high connection churn scenarios
[#160943831]
| -rw-r--r-- | src/rabbit_channel.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 3a90563079..ddcc04e70b 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -2152,6 +2152,7 @@ handle_method(#'queue.declare'{queue = QueueNameBin, end, QueueName = rabbit_misc:r(VHostPath, queue, ActualNameBin), check_configure_permitted(QueueName, User), + rabbit_core_metrics:queue_declared(QueueName), case rabbit_amqqueue:with( QueueName, fun (Q) -> ok = rabbit_amqqueue:assert_equivalence( @@ -2189,6 +2190,7 @@ handle_method(#'queue.declare'{queue = QueueNameBin, _ -> rabbit_queue_collector:register( CollectorPid, QPid) end, + rabbit_core_metrics:queue_created(QueueName), {ok, QueueName, 0, 0}; {existing, _Q} -> %% must have been created between the stat and the |