in java/e2e-v4/src/main/java/org/apache/rocketmq/frame/ResourceInit.java [100:127]
private static void initConnectionInfo() {
allIp = System.getenv("ALL_IP");
if (allIp != null) {
String[] allPodInfos = allIp.split(",");
for (String podInfo : allPodInfos) {
if (podInfo.contains("nameserver")) {
nameserverIpList.add(podInfo.substring(podInfo.indexOf(":") + 1));
} else if (podInfo.contains("broker")) {
brokerIpList.add(podInfo.substring(podInfo.indexOf(":") + 1));
}
}
if (nameserverIpList.isEmpty()) {
log.warn("INIT- Get nameserver from external is empty");
namesrvAddr = System.getProperty("namesrvAddr", properties.getProperty("namesrvAddr"));
} else {
namesrvAddr = nameserverIpList.get(0) + ":" + nameserverPort;
}
} else {
log.info("INIT- Get ALL_IP is null, use local info");
namesrvAddr = System.getProperty("namesrvAddr", properties.getProperty("namesrvAddr"));
}
cluster = System.getenv("cluster") != null ? System.getenv("cluster") : properties.getProperty("cluster");
if (cluster == null) {
log.error("INIT- cluster is null, system exit");
System.exit(-1);
}
log.info("INIT- namesrvAddr:{}, cluster:{}", namesrvAddr, cluster);
}