From a194e1eb9a12e08c43a0da65cd0a048ff849e04d Mon Sep 17 00:00:00 2001 From: dinglei Date: Tue, 28 Nov 2023 20:18:53 +0800 Subject: [PATCH] Add set method for config black list. (#7586) --- .../main/java/org/apache/rocketmq/common/BrokerConfig.java | 4 ++++ .../java/org/apache/rocketmq/common/ControllerConfig.java | 4 ++++ .../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 96e0f8e918b..a4a553ad5bd 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 String getConfigBlackList() { 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 55854cfd2c9..1364754a0d5 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 String getConfigBlackList() { 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 b82d1b8f837..d1cdc7631c2 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 String getConfigBlackList() { return configBlackList; } + public void setConfigBlackList(String configBlackList) { + this.configBlackList = configBlackList; + } + public boolean isOrderMessageEnable() { return orderMessageEnable; }