We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 42405c5 commit f316affCopy full SHA for f316aff
deps/rabbit/src/rabbit_quorum_queue.erl
@@ -2403,7 +2403,7 @@ transfer_leadership(_CandidateNodes) ->
2403
%% wait for leader elections before processing next chunk of queues
2404
[begin
2405
{RaName, LeaderNode} = amqqueue:get_pid(Q),
2406
- MemberNodes = lists:delete(LeaderNode, amqqueue:get_nodes(Q)),
+ MemberNodes = lists:delete(LeaderNode, rabbit_queue_type:get_nodes(Q)),
2407
%% we don't do any explicit error handling here as it is more
2408
%% important to make progress
2409
_ = lists:any(fun (N) ->
0 commit comments