Skip to content

Commit b7f324b

Browse files
SimonUngemergify[bot]
authored andcommitted
Fix so that the code handles a timeout return
(cherry picked from commit dacdeb0)
1 parent 5530a18 commit b7f324b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbit/src/rabbit_quorum_queue_periodic_membership_reconciliation.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ reconciliate_quorum_members(ExpectedNodes, Running, [Q | LocalLeaders],
143143
OldResult) ->
144144
Result =
145145
maybe
146-
{ok, Members, {_, LeaderNode}} = ra:members(amqqueue:get_pid(Q), 500),
146+
{ok, Members, {_, LeaderNode}} ?= ra:members(amqqueue:get_pid(Q), 500),
147147
%% Check if Leader is indeed this node
148148
LeaderNode ?= node(),
149149
%% And that this not is not in maintenance mode

0 commit comments

Comments
 (0)