Fix so that the code handles a timeout return

rabbitmq · Oct 23, 2024 · dacdeb0 · dacdeb0
1 parent 814d44d
commit dacdeb0
Showing 1 changed file with 1 addition and 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
@@ -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