[rocketmq] branch develop updated: add a schedule task to update namesrv address (#4456)

[duhengforever]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new b62d3b2fd add a schedule task to update namesrv address (#4456)
b62d3b2fd is described below

commit b62d3b2fdb831794b55832848dd3ba420f1ab86e
Author: cserwen <cser...@163.com>
AuthorDate: Tue Jun 14 09:42:39 2022 +0800

    add a schedule task to update namesrv address (#4456)
    
    Co-authored-by: dengzhiwen1 <dengzhiw...@xiaomi.com>
---
 .../src/main/java/org/apache/rocketmq/broker/BrokerController.java | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java 
b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
index c2d3fd64a..58616bbe3 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -401,6 +401,13 @@ public class BrokerController {
             if (this.brokerConfig.getNamesrvAddr() != null) {
                 
this.brokerOuterAPI.updateNameServerAddressList(this.brokerConfig.getNamesrvAddr());
                 log.info("Set user specified name server address: {}", 
this.brokerConfig.getNamesrvAddr());
+                this.scheduledExecutorService.scheduleAtFixedRate(() -> {
+                    try {
+                        
BrokerController.this.brokerOuterAPI.updateNameServerAddressList(BrokerController.this.brokerConfig.getNamesrvAddr());
+                    } catch (Throwable e) {
+                        log.error("ScheduledTask updateNameServerAddr 
exception", e);
+                    }
+                }, 1000 * 10, 1000 * 60 * 2, TimeUnit.MILLISECONDS);
             } else if (this.brokerConfig.isFetchNamesrvAddrByAddressServer()) {
                 this.scheduledExecutorService.scheduleAtFixedRate(() -> {
                     try {