root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Start the coordination Ra system before quorum_queues 

This ensures that quorum_queues shuts down _before_
coordination where khepri run inside.
Quorum queues depend on khepri so need to be shut down first.

(cherry picked from commit 274f12f063)
This commit is contained in:
Karl Nilsson 2025-04-09 10:20:37 +01:00 committed by Mergify
parent 438ba1895f
commit 126d03e460
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
deps/rabbit/src/rabbit_ra_systems.erl vendored
View File

@ -43,8 +43,8 @@ setup(_) ->
-spec all_ra_systems() -> [ra_system_name()]. -spec all_ra_systems() -> [ra_system_name()].
all_ra_systems() -> all_ra_systems() ->
[quorum_queues, [coordination,
coordination]. quorum_queues].
-spec are_running() -> AreRunning when -spec are_running() -> AreRunning when
AreRunning :: boolean(). AreRunning :: boolean().
@ -165,7 +165,10 @@ ensure_stopped() ->
?LOG_DEBUG( ?LOG_DEBUG(
"Stopping Ra systems", "Stopping Ra systems",
#{domain => ?RMQLOG_DOMAIN_GLOBAL}), #{domain => ?RMQLOG_DOMAIN_GLOBAL}),
lists:foreach(fun ensure_ra_system_stopped/1, all_ra_systems()), %% lists:reverse/1 is used to stop systems in the same order as would be
%% done if the ra application was terminated.
lists:foreach(fun ensure_ra_system_stopped/1,
lists:reverse(all_ra_systems())),
?LOG_DEBUG( ?LOG_DEBUG(
"Ra systems stopped", "Ra systems stopped",
#{domain => ?RMQLOG_DOMAIN_GLOBAL}), #{domain => ?RMQLOG_DOMAIN_GLOBAL}),