diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2021-09-19 18:59:08 +0300 |
|---|---|---|
| committer | mergify-bot <noreply@mergify.io> | 2021-09-19 17:25:18 +0000 |
| commit | f32f9f78fbbe7fa865ce5867ef40590747d816eb (patch) | |
| tree | 34ff1f75a4ad6ed399075fd49131b48d2823af02 | |
| parent | 9ef0f139a132366bd12a620f8d7842ec01837248 (diff) | |
| download | rabbitmq-server-git-mergify/bp/v3.9.x/pr-3454.tar.gz | |
Emit a node.added event when a new node joins the clustermergify/bp/v3.9.x/pr-3454
(cherry picked from commit c8781e5da7495b98a5f99df34fa20d3e7dd44f3c)
| -rw-r--r-- | deps/rabbit/src/rabbit_node_monitor.erl | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/deps/rabbit/src/rabbit_node_monitor.erl b/deps/rabbit/src/rabbit_node_monitor.erl index 9c1231b80f..72ed13743f 100644 --- a/deps/rabbit/src/rabbit_node_monitor.erl +++ b/deps/rabbit/src/rabbit_node_monitor.erl @@ -166,9 +166,11 @@ notify_node_up() -> -spec notify_joined_cluster() -> 'ok'. notify_joined_cluster() -> - Nodes = rabbit_nodes:all_running() -- [node()], + NewMember = node(), + Nodes = rabbit_nodes:all_running() -- [NewMember], gen_server:abcast(Nodes, ?SERVER, {joined_cluster, node(), rabbit_mnesia:node_type()}), + ok. -spec notify_left_cluster(node()) -> 'ok'. @@ -536,6 +538,8 @@ handle_cast({joined_cluster, Node, NodeType}, State) -> ram -> DiscNodes end, RunningNodes}), + rabbit_log:debug("Node '~p' has joined the cluster", [Node]), + rabbit_event:notify(node_added, [{node, Node}]), {noreply, State}; handle_cast({left_cluster, Node}, State) -> |