diff options
| author | Gerhard Lazu <gerhard@lazu.co.uk> | 2018-02-23 10:01:14 +0000 |
|---|---|---|
| committer | Gerhard Lazu <gerhard@lazu.co.uk> | 2018-03-27 16:07:35 +0100 |
| commit | a94faecc98f4f40fe7a649d564b9025cbe5736b6 (patch) | |
| tree | ffdac0db079aaf0ee4c8515e41c8ae8f2768d53d /src | |
| parent | 52dba0346cf092d9f6160ab7776487ed24df408a (diff) | |
| download | rabbitmq-server-git-a94faecc98f4f40fe7a649d564b9025cbe5736b6.tar.gz | |
Add back INTERNAL_USER info to on_node_down function
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index d661be84b6..f14b19aa3d 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -1130,7 +1130,8 @@ on_node_down(Node) -> fun () -> Dels = [delete_queue(Q)], T = rabbit_binding:process_deletions( lists:foldl(fun rabbit_binding:combine_deletions/2, - rabbit_binding:new_deletions(), Dels)), + rabbit_binding:new_deletions(), Dels), + ?INTERNAL_USER), fun () -> T(), lists:foreach( @@ -1155,7 +1156,8 @@ on_node_down(Node) -> % [{file,"src/rabbit_node_monitor.erl"},{line,548}]}]} rabbit_core_metrics:queue_deleted(QName), ok = rabbit_event:notify(queue_deleted, - [{name, QName}]) + [{name, QName}, + {user, ?INTERNAL_USER}]) end, [Q]) end end) || Q <- queues_to_delete_from_node_down(Node) |