diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2016-08-10 20:18:33 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2016-08-10 20:18:33 +0300 |
| commit | ede361d09288eb8a04cf55f0f7e53f01c069d6c0 (patch) | |
| tree | 9d23414fa361731918aeb6bd043de4311765faaf | |
| parent | efc0f993e1e66b724f22be77bbc1d3830b2ddcdb (diff) | |
| download | rabbitmq-server-git-ede361d09288eb8a04cf55f0f7e53f01c069d6c0.tar.gz | |
Emit a node_deleted event when a node is removed from the cluster
| -rw-r--r-- | src/rabbit_mnesia.erl | 4 |
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. |
