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 c30cd64 commit e5d9071Copy full SHA for e5d9071
deps/rabbit/src/rabbit_quorum_queue.erl
@@ -1749,10 +1749,10 @@ force_all_queues_shrink_member_to_current_member() ->
1749
{RaName, _} = amqqueue:get_pid(Q),
1750
rabbit_log:warning("Disaster recovery procedure: shrinking queue ~p", [QName]),
1751
ok = ra_server_proc:force_shrink_members_to_current_member({RaName, Node}),
1752
- Fun = fun (Q) ->
1753
- TS0 = amqqueue:get_type_state(Q),
+ Fun = fun (QQ) ->
+ TS0 = amqqueue:get_type_state(QQ),
1754
TS = TS0#{nodes => [Node]},
1755
- amqqueue:set_type_state(Q, TS)
+ amqqueue:set_type_state(QQ, TS)
1756
end,
1757
_ = rabbit_amqqueue:update(QName, Fun)
1758
end || Q <- rabbit_amqqueue:list(), amqqueue:get_type(Q) == ?MODULE],
0 commit comments