diff options
| author | Michael Klishin <michael@novemberain.com> | 2018-10-11 02:16:59 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-10-11 02:16:59 +0300 |
| commit | 5e5d8dac8e2635b48e124c77723197d73f4dd2fb (patch) | |
| tree | 669325c922c29acfe11c1ae3964076966d906c2e /src | |
| parent | 3ae27d2e5a0128c65d1e1312a23ef72103298e9a (diff) | |
| parent | a819043a31cdea3ff8af37d89ee6bd58a8813d93 (diff) | |
| download | rabbitmq-server-git-5e5d8dac8e2635b48e124c77723197d73f4dd2fb.tar.gz | |
Merge pull request #1726 from rabbitmq/rabbitmq-server-1723
Report connection/channel/queue churn
Diffstat (limited to 'src')
| -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 |