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 60b5a13 commit a727682Copy full SHA for a727682
deps/rabbit/src/rabbit_quorum_queue.erl
@@ -2392,7 +2392,7 @@ transfer_leadership(_CandidateNodes) ->
2392
%% wait for leader elections before processing next chunk of queues
2393
[begin
2394
{RaName, LeaderNode} = amqqueue:get_pid(Q),
2395
- MemberNodes = lists:delete(LeaderNode, amqqueue:get_nodes(Q)),
+ MemberNodes = lists:delete(LeaderNode, rabbit_queue_type:get_nodes(Q)),
2396
%% we don't do any explicit error handling here as it is more
2397
%% important to make progress
2398
_ = lists:any(fun (N) ->
0 commit comments