Skip to content

Commit a94faec

Browse files
committed
Add back INTERNAL_USER info to on_node_down function
1 parent 52dba03 commit a94faec

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

src/rabbit_amqqueue.erl

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1130,7 +1130,8 @@ on_node_down(Node) ->
11301130
fun () -> Dels = [delete_queue(Q)],
11311131
T = rabbit_binding:process_deletions(
11321132
lists:foldl(fun rabbit_binding:combine_deletions/2,
1133-
rabbit_binding:new_deletions(), Dels)),
1133+
rabbit_binding:new_deletions(), Dels),
1134+
?INTERNAL_USER),
11341135
fun () ->
11351136
T(),
11361137
lists:foreach(
@@ -1155,7 +1156,8 @@ on_node_down(Node) ->
11551156
% [{file,"src/rabbit_node_monitor.erl"},{line,548}]}]}
11561157
rabbit_core_metrics:queue_deleted(QName),
11571158
ok = rabbit_event:notify(queue_deleted,
1158-
[{name, QName}])
1159+
[{name, QName},
1160+
{user, ?INTERNAL_USER}])
11591161
end, [Q])
11601162
end
11611163
end) || Q <- queues_to_delete_from_node_down(Node)

0 commit comments

Comments
 (0)