Skip to content

Commit 49365b8

Browse files
Merge pull request #8124 from rabbitmq/mergify/bp/v3.12.x/pr-8123
Peer discovery: shrink QQ replicas on forced node removal (backport #8123)
2 parents 985b9a9 + 64a8ed5 commit 49365b8

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

deps/rabbitmq_peer_discovery_common/src/rabbit_peer_discovery_cleanup.erl

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -277,7 +277,11 @@ maybe_remove_nodes([Node | Nodes], false) ->
277277
?LOG_WARNING(
278278
"Peer discovery: removing unknown node ~ts from the cluster", [Node],
279279
#{domain => ?RMQLOG_DOMAIN_PEER_DIS}),
280-
rabbit_mnesia:forget_cluster_node(Node, false),
280+
_ = rabbit_mnesia:forget_cluster_node(Node, false),
281+
?LOG_WARNING(
282+
"Peer discovery: removing all quorum queue replicas on node ~ts", [Node],
283+
#{domain => ?RMQLOG_DOMAIN_PEER_DIS}),
284+
_ = rabbit_quorum_queue:shrink_all(Node),
281285
maybe_remove_nodes(Nodes, false).
282286

283287
%%--------------------------------------------------------------------

0 commit comments

Comments
 (0)