@@ -1744,17 +1744,17 @@ force_shrink_member_to_current_member(VHost, Name) ->
1744
1744
force_all_queues_shrink_member_to_current_member () ->
1745
1745
rabbit_log :warning (" Disaster recovery procedure: shrinking all quorum queues to a single node cluster" ),
1746
1746
Node = node (),
1747
- [begin
1748
- QName = amqqueue :get_name (Q ),
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 (QQ ) ->
1753
- TS0 = amqqueue :get_type_state (QQ ),
1754
- TS = TS0 #{nodes => [Node ]},
1755
- 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 ],
1747
+ _ = [begin
1748
+ QName = amqqueue :get_name (Q ),
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 (QQ ) ->
1753
+ TS0 = amqqueue :get_type_state (QQ ),
1754
+ TS = TS0 #{nodes => [Node ]},
1755
+ 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 ],
1759
1759
rabbit_log :warning (" Disaster recovery procedure: shrinking finished" ),
1760
1760
ok .
0 commit comments