Let QQs check if it needs to repair amqqueue nodes

SimonUnge · May 20, 2024 · ce90f5d · ce90f5d
1 parent 21be5e9
commit ce90f5d
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/deps/rabbit/src/rabbit_quorum_queue.erl b/deps/rabbit/src/rabbit_quorum_queue.erl
@@ -552,6 +552,7 @@ handle_tick(QName,
                            | info(Q, Keys)],
                   rabbit_core_metrics:queue_stats(QName, Infos),
                   ok = repair_leader_record(Q, Self),
+                  repair_amqqueue_nodes(Q),
                   ExpectedNodes = rabbit_nodes:list_members(),
                   case Nodes -- ExpectedNodes of
                       [] ->