[rocketmq] branch develop updated: [ISSUE #7497] Extract the frequency of calling updateNamesrvAddr into a configuration (#7498)

[fuyou]

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

fuyou 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 f90c55341c [ISSUE #7497] Extract the frequency of calling 
updateNamesrvAddr into a configuration (#7498)
f90c55341c is described below

commit f90c55341ce253f6b532a83de47172ad14928e9e
Author: lk <xdk...@outlook.com>
AuthorDate: Tue Oct 24 16:13:36 2023 +0800

    [ISSUE #7497] Extract the frequency of calling updateNamesrvAddr into a 
configuration (#7498)
    
    merge
---
 .../java/org/apache/rocketmq/container/BrokerContainer.java |  2 +-
 .../apache/rocketmq/container/BrokerContainerConfig.java    | 13 +++++++++++++
 2 files changed, 14 insertions(+), 1 deletion(-)

diff --git 
a/container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java 
b/container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java
index 5b712bc30d..d0a550be63 100644
--- a/container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java
+++ b/container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java
@@ -164,7 +164,7 @@ public class BrokerContainer implements IBrokerContainer {
                         LOG.error("ScheduledTask fetchNameServerAddr 
exception", e);
                     }
                 }
-            }, 1000 * 10, 1000 * 60 * 2, TimeUnit.MILLISECONDS);
+            }, 1000 * 10, 
this.brokerContainerConfig.getUpdateNamesrvAddrInterval(), 
TimeUnit.MILLISECONDS);
         } else if 
(this.brokerContainerConfig.isFetchNamesrvAddrByAddressServer()) {
             this.scheduledExecutorService.scheduleAtFixedRate(new 
AbstractBrokerRunnable(BrokerIdentity.BROKER_CONTAINER_IDENTITY) {
 
diff --git 
a/container/src/main/java/org/apache/rocketmq/container/BrokerContainerConfig.java
 
b/container/src/main/java/org/apache/rocketmq/container/BrokerContainerConfig.java
index 77422adde8..e03b10c34d 100644
--- 
a/container/src/main/java/org/apache/rocketmq/container/BrokerContainerConfig.java
+++ 
b/container/src/main/java/org/apache/rocketmq/container/BrokerContainerConfig.java
@@ -44,6 +44,11 @@ public class BrokerContainerConfig {
      */
     private long fetchNamesrvAddrInterval = 10 * 1000;
 
+    /**
+     * The interval to update namesrv addr, default value is 120 second
+     */
+    private long updateNamesrvAddrInterval = 60 * 2 * 1000;
+
     public String getRocketmqHome() {
         return rocketmqHome;
     }
@@ -95,4 +100,12 @@ public class BrokerContainerConfig {
     public void setFetchNamesrvAddrInterval(final long 
fetchNamesrvAddrInterval) {
         this.fetchNamesrvAddrInterval = fetchNamesrvAddrInterval;
     }
+
+    public long getUpdateNamesrvAddrInterval() {
+        return updateNamesrvAddrInterval;
+    }
+
+    public void setUpdateNamesrvAddrInterval(long updateNamesrvAddrInterval) {
+        this.updateNamesrvAddrInterval = updateNamesrvAddrInterval;
+    }
 }