This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 a194e1eb9a Add set method for config black list. (#7586)
a194e1eb9a is described below
commit a194e1eb9a12e08c43a0da65cd0a048ff849e04d
Author: dinglei <[email protected]>
AuthorDate: Tue Nov 28 20:18:53 2023 +0800
Add set method for config black list. (#7586)
---
common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java | 4 ++++
common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java | 4 ++++
.../main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java | 4 ++++
3 files changed, 12 insertions(+)
diff --git a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
index 96e0f8e918..a4a553ad5b 100644
--- a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
+++ b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
@@ -417,6 +417,10 @@ public class BrokerConfig extends BrokerIdentity {
return configBlackList;
}
+ public void setConfigBlackList(String configBlackList) {
+ this.configBlackList = configBlackList;
+ }
+
public long getMaxPopPollingSize() {
return maxPopPollingSize;
}
diff --git
a/common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java
b/common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java
index 55854cfd2c..1364754a0d 100644
--- a/common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java
+++ b/common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java
@@ -94,6 +94,10 @@ public class ControllerConfig {
return configBlackList;
}
+ public void setConfigBlackList(String configBlackList) {
+ this.configBlackList = configBlackList;
+ }
+
public String getRocketmqHome() {
return rocketmqHome;
}
diff --git
a/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java
b/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java
index b82d1b8f83..d1cdc7631c 100644
--- a/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java
+++ b/common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java
@@ -101,6 +101,10 @@ public class NamesrvConfig {
return configBlackList;
}
+ public void setConfigBlackList(String configBlackList) {
+ this.configBlackList = configBlackList;
+ }
+
public boolean isOrderMessageEnable() {
return orderMessageEnable;
}