| commit | fb1c67d536c95ec7bd5904e61b9d97c4c2ee5a3d | [log] [tgz] |
|---|---|---|
| author | rongtong <jinrongtong5@163.com> | Thu Jun 01 16:38:29 2023 +0800 |
| committer | GitHub <noreply@github.com> | Thu Jun 01 16:38:29 2023 +0800 |
| tree | f58ee7cdc99a2f28e4a70cc1cfea480717d61b17 | |
| parent | c68fb8f1b9ee1a7b69e087a101bf1783e2b8140b [diff] |
Fix incorrect naming (#6843)
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 8220507..fada0ef 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
@@ -627,7 +627,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/RequestProcessorTest.java b/namesrv/src/test/java/org/apache/rocketmq/namesrv/processor/RequestProcessorTest.java index 8e7a21d..5bdf96d 100644 --- a/namesrv/src/test/java/org/apache/rocketmq/namesrv/processor/RequestProcessorTest.java +++ b/namesrv/src/test/java/org/apache/rocketmq/namesrv/processor/RequestProcessorTest.java
@@ -196,7 +196,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);