| commit | e07754f2ab4c637e9acbc1452de03375c4867dce | [log] [tgz] |
|---|---|---|
| author | RongtongJin <jinrongtong16@mails.ucas.ac.cn> | Mon Jun 12 16:28:42 2023 +0800 |
| committer | RongtongJin <jinrongtong16@mails.ucas.ac.cn> | Mon Jun 12 16:28:42 2023 +0800 |
| tree | 3ec4aa2e77e83f463d576eb201824cc547c39ab4 | |
| parent | 7d9c79bbeee9d1d8a906e3f3ba6231551e8f993b [diff] |
Fix incorrect naming in update configuration protection
diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java index 0efef1b..e679dca 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
@@ -581,7 +581,7 @@ return response; } - if (properties.containsKey("kvConfigPath") || properties.containsKey("configStorePathName")) { + if (properties.containsKey("kvConfigPath") || properties.containsKey("configStorePath")) { response.setCode(ResponseCode.NO_PERMISSION); response.setRemark("Can not update config path"); return response;
diff --git a/namesrv/src/test/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessorTest.java b/namesrv/src/test/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessorTest.java index 329fe53..f22031e 100644 --- a/namesrv/src/test/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessorTest.java +++ b/namesrv/src/test/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessorTest.java
@@ -178,7 +178,7 @@ //update disallowed value properties.clear(); - properties.setProperty("configStorePathName", "test/path"); + properties.setProperty("configStorePath", "test/path"); updateConfigRequest.setBody(MixAll.properties2String(properties).getBytes(StandardCharsets.UTF_8)); response = defaultRequestProcessor.processRequest(null, updateConfigRequest);