in java/e2e-v4/src/main/java/org/apache/rocketmq/frame/ResourceInit.java [65:85]
private static void initResource() {
try {
String env = System.getProperty("env", "daily");
String region = System.getProperty("region", "daily");
InputStream inputStream = new FileInputStream(String.format("src/test/resources/env/%s/%s.conf", env, region));
log.info("INIT - use config env:{}, config:{}", env, region);
properties = configFileHelper.loadConfig(inputStream);
} catch (Exception e) {
log.error(ExceptionUtils.getStackTrace(e));
log.info("INIT - execute error,exit the process");
System.exit(0);
}
// init endpoint and nameserver
initConnectionInfo();
initAcl();
String namesrvAddrIp = namesrvAddr.substring(0, namesrvAddr.indexOf(":"));
String namesrvAddrPort = namesrvAddr.substring(namesrvAddr.lastIndexOf(":") + 1);
checkConnection(namesrvAddrIp, namesrvAddrPort);
}