summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_channel.erl2
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