From b7f324b27b7c7e8523e81571ab776ed8de4e69cc Mon Sep 17 00:00:00 2001 From: Simon Unge Date: Wed, 23 Oct 2024 23:12:36 +0000 Subject: [PATCH] Fix so that the code handles a timeout return (cherry picked from commit dacdeb024dd8f20cc09fb83e2ab86a8b14d4bb04) --- .../rabbit_quorum_queue_periodic_membership_reconciliation.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/deps/rabbit/src/rabbit_quorum_queue_periodic_membership_reconciliation.erl b/deps/rabbit/src/rabbit_quorum_queue_periodic_membership_reconciliation.erl index 81029c9b145c..4340993d96c4 100644 --- a/deps/rabbit/src/rabbit_quorum_queue_periodic_membership_reconciliation.erl +++ b/deps/rabbit/src/rabbit_quorum_queue_periodic_membership_reconciliation.erl @@ -143,7 +143,7 @@ reconciliate_quorum_members(ExpectedNodes, Running, [Q | LocalLeaders], OldResult) -> Result = maybe - {ok, Members, {_, LeaderNode}} = ra:members(amqqueue:get_pid(Q), 500), + {ok, Members, {_, LeaderNode}} ?= ra:members(amqqueue:get_pid(Q), 500), %% Check if Leader is indeed this node LeaderNode ?= node(), %% And that this not is not in maintenance mode