in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java [370:395]
private void checkNetworkType(NetworkParameters networkParameters) {
if (networkParameters == null) {
throw new EventBridgeException(EventBridgeErrorCode.NetworkParametersIsNull);
}
String type = networkParameters.getNetworkType();
if (StringUtils.isBlank(type)) {
throw new EventBridgeException(EventBridgeErrorCode.NetworkTypeIsBlank);
}
boolean check = true;
for (NetworkTypeEnum networkTypeEnum : NetworkTypeEnum.values()) {
if (networkTypeEnum.getNetworkType().equals(type)) {
check = false;
break;
}
}
if (check) {
throw new EventBridgeException(EventBridgeErrorCode.ConnectionNetworkParametersInvalid);
}
if (NetworkTypeEnum.PRIVATE_NETWORK.getNetworkType().equals(type)) {
if (StringUtils.isBlank(networkParameters.getVpcId())
|| StringUtils.isBlank(networkParameters.getVswitcheId())
|| StringUtils.isBlank(networkParameters.getSecurityGroupId())) {
throw new EventBridgeException(EventBridgeErrorCode.NetworkParametersIsEmpty);
}
}
}