You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/06/14 01:42:59 UTC
[rocketmq] branch develop updated: add a schedule task to update namesrv address (#4456)
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 <cs...@163.com>
AuthorDate: Tue Jun 14 09:42:39 2022 +0800
add a schedule task to update namesrv address (#4456)
Co-authored-by: dengzhiwen1 <de...@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 {