Skip to content

Commit d644976

Browse files
Merge pull request #3455 from rabbitmq/mergify/bp/v3.9.x/pr-3454
Emit a node.added event when a new node joins the cluster (backport #3454)
2 parents 9ef0f13 + f32f9f7 commit d644976

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

deps/rabbit/src/rabbit_node_monitor.erl

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -166,9 +166,11 @@ notify_node_up() ->
166166
-spec notify_joined_cluster() -> 'ok'.
167167

168168
notify_joined_cluster() ->
169-
Nodes = rabbit_nodes:all_running() -- [node()],
169+
NewMember = node(),
170+
Nodes = rabbit_nodes:all_running() -- [NewMember],
170171
gen_server:abcast(Nodes, ?SERVER,
171172
{joined_cluster, node(), rabbit_mnesia:node_type()}),
173+
172174
ok.
173175

174176
-spec notify_left_cluster(node()) -> 'ok'.
@@ -536,6 +538,8 @@ handle_cast({joined_cluster, Node, NodeType}, State) ->
536538
ram -> DiscNodes
537539
end,
538540
RunningNodes}),
541+
rabbit_log:debug("Node '~p' has joined the cluster", [Node]),
542+
rabbit_event:notify(node_added, [{node, Node}]),
539543
{noreply, State};
540544

541545
handle_cast({left_cluster, Node}, State) ->

0 commit comments

Comments
 (0)