From b74dea443595520c38174745eb49d98ba85e719e Mon Sep 17 00:00:00 2001 From: Chunyi Lyu Date: Thu, 27 Oct 2022 12:17:26 +0100 Subject: [PATCH] Send rabbit event declaring mqtt_qos0 queue --- deps/rabbitmq_mqtt/src/rabbit_mqtt_qos0_queue.erl | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/deps/rabbitmq_mqtt/src/rabbit_mqtt_qos0_queue.erl b/deps/rabbitmq_mqtt/src/rabbit_mqtt_qos0_queue.erl index c5260e6cd5..8cfb582a4c 100644 --- a/deps/rabbitmq_mqtt/src/rabbit_mqtt_qos0_queue.erl +++ b/deps/rabbitmq_mqtt/src/rabbit_mqtt_qos0_queue.erl @@ -59,6 +59,15 @@ declare(Q0, _Node) -> %% queue (via the topic exchange) works as usual. case rabbit_amqqueue:internal_declare(Q0, false) of {created, Q} -> + Opts = amqqueue:get_options(Q), + ActingUser = maps:get(user, Opts, ?UNKNOWN_USER), + rabbit_event:notify(queue_created, + [{name, amqqueue:get_name(Q0)}, + {durable, true}, + {auto_delete, false}, + {type, amqqueue:get_type(Q0)}, + {arguments, amqqueue:get_arguments(Q0)}, + {user_who_performed_action, ActingUser}]), {new, Q}; Other -> Other