This is an automated email from the ASF dual-hosted git repository.
lizhimin 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 7cc077416e [ISSUE #9964] Rename intConfig method to initConfig (#9965)
7cc077416e is described below
commit 7cc077416ec205326e4cfc48071f18a904ea0ede
Author: yx9o <[email protected]>
AuthorDate: Sun Jan 4 17:46:20 2026 +0800
[ISSUE #9964] Rename intConfig method to initConfig (#9965)
---
proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java | 2 +-
.../java/org/apache/rocketmq/proxy/config/ConfigurationManager.java | 2 +-
.../java/org/apache/rocketmq/proxy/config/ConfigurationManagerTest.java | 2 +-
.../src/test/java/org/apache/rocketmq/proxy/config/InitConfigTest.java | 2 +-
.../apache/rocketmq/proxy/grpc/ProxyAndTlsProtocolNegotiatorTest.java | 2 +-
.../rocketmq/proxy/remoting/activity/GetTopicRouteActivityTest.java | 2 +-
.../apache/rocketmq/proxy/service/cert/TlsCertificateManagerTest.java | 2 +-
test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java | 2 +-
8 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java
b/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java
index 131faffa38..1b38a19ae6 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java
@@ -122,7 +122,7 @@ public class ProxyStartup {
System.setProperty(Configuration.CONFIG_PATH_PROPERTY,
commandLineArgument.getProxyConfigPath());
}
ConfigurationManager.initEnv();
- ConfigurationManager.intConfig();
+ ConfigurationManager.initConfig();
setConfigFromCommandLineArgument(commandLineArgument);
log.info("Current configuration: " +
ConfigurationManager.formatProxyConfig());
diff --git
a/proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java
b/proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java
index 4660610ecd..f85221960f 100644
---
a/proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java
+++
b/proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java
@@ -40,7 +40,7 @@ public class ConfigurationManager {
}
}
- public static void intConfig() throws Exception {
+ public static void initConfig() throws Exception {
configuration = new Configuration();
configuration.init();
}
diff --git
a/proxy/src/test/java/org/apache/rocketmq/proxy/config/ConfigurationManagerTest.java
b/proxy/src/test/java/org/apache/rocketmq/proxy/config/ConfigurationManagerTest.java
index 2caa4e37e9..50c02d40ff 100644
---
a/proxy/src/test/java/org/apache/rocketmq/proxy/config/ConfigurationManagerTest.java
+++
b/proxy/src/test/java/org/apache/rocketmq/proxy/config/ConfigurationManagerTest.java
@@ -27,7 +27,7 @@ import static org.junit.Assert.assertTrue;
public class ConfigurationManagerTest extends InitConfigTest {
@Test
- public void testIntConfig() {
+ public void testInitConfig() {
assertThat(ConfigurationManager.getProxyConfig()).isNotNull();
assertThat(ConfigurationManager.getProxyConfig().getProxyMode()).isEqualToIgnoringCase(ProxyMode.CLUSTER.toString());
diff --git
a/proxy/src/test/java/org/apache/rocketmq/proxy/config/InitConfigTest.java
b/proxy/src/test/java/org/apache/rocketmq/proxy/config/InitConfigTest.java
index d71d163ac6..0bd5126040 100644
--- a/proxy/src/test/java/org/apache/rocketmq/proxy/config/InitConfigTest.java
+++ b/proxy/src/test/java/org/apache/rocketmq/proxy/config/InitConfigTest.java
@@ -40,7 +40,7 @@ public class InitConfigTest {
}
ConfigurationManager.initEnv();
- ConfigurationManager.intConfig();
+ ConfigurationManager.initConfig();
}
@After
diff --git
a/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/ProxyAndTlsProtocolNegotiatorTest.java
b/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/ProxyAndTlsProtocolNegotiatorTest.java
index 699491f03d..9034da7f36 100644
---
a/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/ProxyAndTlsProtocolNegotiatorTest.java
+++
b/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/ProxyAndTlsProtocolNegotiatorTest.java
@@ -34,7 +34,7 @@ public class ProxyAndTlsProtocolNegotiatorTest {
@Before
public void setUp() throws Exception {
- ConfigurationManager.intConfig();
+ ConfigurationManager.initConfig();
ConfigurationManager.getProxyConfig().setTlsTestModeEnable(true);
negotiator = new ProxyAndTlsProtocolNegotiator();
}
diff --git
a/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/GetTopicRouteActivityTest.java
b/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/GetTopicRouteActivityTest.java
index d956da52a1..1aaa800bf7 100644
---
a/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/GetTopicRouteActivityTest.java
+++
b/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/GetTopicRouteActivityTest.java
@@ -75,7 +75,7 @@ public class GetTopicRouteActivityTest {
getTopicRouteActivity = new GetTopicRouteActivity(requestPipeline,
messagingProcessor);
ConfigurationManager.initEnv();
- ConfigurationManager.intConfig();
+ ConfigurationManager.initConfig();
Channel channel = new SimpleChannel(null, "0.0.0.0:0", "1.1.1.1:1");
ctx = new SimpleChannelHandlerContext(channel);
diff --git
a/proxy/src/test/java/org/apache/rocketmq/proxy/service/cert/TlsCertificateManagerTest.java
b/proxy/src/test/java/org/apache/rocketmq/proxy/service/cert/TlsCertificateManagerTest.java
index 2e3d2e9aae..9e5f541746 100644
---
a/proxy/src/test/java/org/apache/rocketmq/proxy/service/cert/TlsCertificateManagerTest.java
+++
b/proxy/src/test/java/org/apache/rocketmq/proxy/service/cert/TlsCertificateManagerTest.java
@@ -71,7 +71,7 @@ public class TlsCertificateManagerTest {
@Before
public void setUp() throws Exception {
ConfigurationManager.initEnv();
- ConfigurationManager.intConfig();
+ ConfigurationManager.initConfig();
// Create temporary certificate and key files
certFile = tempDir.newFile("server.crt");
keyFile = tempDir.newFile("server.key");
diff --git
a/test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java
b/test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java
index 724aa114f1..47d0e974e0 100644
--- a/test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java
+++ b/test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java
@@ -153,7 +153,7 @@ public class GrpcBaseIT extends BaseConf {
}
ConfigurationManager.initEnv();
- ConfigurationManager.intConfig();
+ ConfigurationManager.initConfig();
ConfigurationManager.getProxyConfig().setNamesrvAddr(NAMESRV_ADDR);
// Set LongPollingReserveTimeInMillis to 500ms to reserve more time
for IT
ConfigurationManager.getProxyConfig().setLongPollingReserveTimeInMillis(500);
