opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-29 04:13:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #9978] Remove static from loadJsonConfig and unify exception strings (#9979)

Browse Source
This commit is contained in:
yx9o
2026-01-14 10:36:46 +08:00
committed by GitHub
parent b6cc188bfa
commit 500c46866a
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/config/Configuration.java
+7 -5
View File
@@ -51,7 +51,7 @@ public class Configuration {
authConfig.setClusterName(proxyConfig.getRocketMQClusterName());
}
public static String loadJsonConfig() throws Exception {
private String loadJsonConfig() throws Exception {
String configFileName = ProxyConfig.DEFAULT_CONFIG_FILE_NAME;
String filePath = System.getProperty(CONFIG_PATH_PROPERTY);
if (StringUtils.isBlank(filePath)) {
@@ -67,13 +67,15 @@ public class Configuration {
File file = new File(filePath);
log.info("The current configuration file path is {}", filePath);
if (!file.exists()) {
log.warn("the config file {} not exist", filePath);
throw new RuntimeException(String.format("the config file %s not exist", filePath));
String msg = String.format("the config file %s not exist", filePath);
log.warn(msg);
throw new RuntimeException(msg);
}
long fileLength = file.length();
if (fileLength <= 0) {
log.warn("the config file {} length is zero", filePath);
throw new RuntimeException(String.format("the config file %s length is zero", filePath));
String msg = String.format("the config file %s length is zero", filePath);
log.warn(msg);
throw new RuntimeException(msg);
}
return new String(Files.readAllBytes(file.toPath()), StandardCharsets.UTF_8);