From c1fdf1d62c627d6cfbae06d0e15f1c23c7be654b Mon Sep 17 00:00:00 2001 From: RongtongJin Date: Thu, 1 Jun 2023 09:50:49 +0800 Subject: [PATCH] Fix incorrect naming --- .../rocketmq/namesrv/processor/DefaultRequestProcessor.java | 2 +- .../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 8220507d25e..fada0efd774 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 @@ 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/RequestProcessorTest.java b/namesrv/src/test/java/org/apache/rocketmq/namesrv/processor/RequestProcessorTest.java index 8e7a21d98e7..5bdf96d9de7 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 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);