mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-29 04:13:00 +08:00
This commit is contained in:
@@ -115,7 +115,7 @@ public class NamesrvController {
|
||||
|
||||
private void startScheduleService() {
|
||||
this.scanExecutorService.scheduleAtFixedRate(NamesrvController.this.routeInfoManager::scanNotActiveBroker,
|
||||
5, this.namesrvConfig.getScanNotActiveBrokerInterval(), TimeUnit.MILLISECONDS);
|
||||
5000, this.namesrvConfig.getScanNotActiveBrokerInterval(), TimeUnit.MILLISECONDS);
|
||||
|
||||
this.scheduledExecutorService.scheduleAtFixedRate(NamesrvController.this.kvConfigManager::printAllPeriodically,
|
||||
1, 10, TimeUnit.MINUTES);
|
||||
|
||||
Reference in New Issue
Block a user