summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <mklishin@pivotal.io>2016-08-10 20:18:33 +0300
committerMichael Klishin <mklishin@pivotal.io>2016-08-10 20:18:33 +0300
commitede361d09288eb8a04cf55f0f7e53f01c069d6c0 (patch)
tree9d23414fa361731918aeb6bd043de4311765faaf
parentefc0f993e1e66b724f22be77bbc1d3830b2ddcdb (diff)
downloadrabbitmq-server-git-ede361d09288eb8a04cf55f0f7e53f01c069d6c0.tar.gz
Emit a node_deleted event when a node is removed from the cluster
-rw-r--r--src/rabbit_mnesia.erl4
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index 0c46193ca3..a1cfe0948f 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -308,7 +308,9 @@ forget_cluster_node(Node, RemoveWhenOffline) ->
{false, true} -> rabbit_log:info(
"Removing node ~p from cluster~n", [Node]),
case remove_node_if_mnesia_running(Node) of
- ok -> ok;
+ ok ->
+ rabbit_event:notify(node_deleted, [{node, Node}]),
+ ok;
{error, _} = Err -> throw(Err)
end
end.