[rocketmq] branch develop updated: Fix incorrect naming (#6843)

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei 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 fb1c67d536 Fix incorrect naming (#6843)
fb1c67d536 is described below

commit fb1c67d536c95ec7bd5904e61b9d97c4c2ee5a3d
Author: rongtong <jinrongto...@163.com>
AuthorDate: Thu Jun 1 16:38:29 2023 +0800

    Fix incorrect naming (#6843)
---
 .../org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java  | 2 +-
 .../org/apache/rocketmq/namesrv/processor/RequestProcessorTest.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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 8220507d25..fada0efd77 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 @@ public class DefaultRequestProcessor implements 
NettyRequestProcessor {
                 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 8e7a21d98e..5bdf96d9de 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 @@ public class RequestProcessorTest {
 
         //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);