@@ -583,6 +583,7 @@ handle_tick(QName,
583
583
fun () ->
584
584
try
585
585
{ok , Q } = rabbit_amqqueue :lookup (QName ),
586
+ ok = repair_leader_record (Q , Name ),
586
587
Reductions = reductions (Name ),
587
588
rabbit_core_metrics :queue_stats (QName , NumReadyMsgs ,
588
589
NumCheckedOut , NumMessages ,
@@ -636,7 +637,6 @@ handle_tick(QName,
636
637
end }
637
638
| Infos0 ],
638
639
rabbit_core_metrics :queue_stats (QName , Infos ),
639
- ok = repair_leader_record (Q , Name ),
640
640
case repair_amqqueue_nodes (Q ) of
641
641
ok ->
642
642
ok ;
@@ -1763,7 +1763,7 @@ i(leader, Q) -> leader(Q);
1763
1763
i (open_files , Q ) when ? is_amqqueue (Q ) ->
1764
1764
{Name , _ } = amqqueue :get_pid (Q ),
1765
1765
Nodes = get_connected_nodes (Q ),
1766
- {Data , _ } = rpc :multicall (Nodes , ? MODULE , open_files , [Name ]),
1766
+ {Data , _ } = rpc :multicall (Nodes , ? MODULE , open_files , [Name ], ? RPC_TIMEOUT ),
1767
1767
lists :flatten (Data );
1768
1768
i (single_active_consumer_pid , Q ) when ? is_amqqueue (Q ) ->
1769
1769
QPid = amqqueue :get_pid (Q ),
0 commit comments