Fix incorrect naming in update configuration protection

apache · Jun 12, 2023 · e07754f · e07754f
1 parent 7d9c79b
commit e07754f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 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
@@ -581,7 +581,7 @@ private RemotingCommand updateConfig(ChannelHandlerContext ctx, RemotingCommand
                 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
@@ -178,7 +178,7 @@ public void testProcessRequest_UpdateConfigPath() throws RemotingCommandExceptio
 
         //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);