in registry/nacos/src/lib.rs [141:176]
fn register(&mut self, url: Url) -> Result<(), dubbo::StdError> {
let side = url.get_param(SIDE_KEY).unwrap_or_default();
let register_consumer = url
.get_param(REGISTER_CONSUMER_URL_KEY)
.unwrap_or_else(|| false.to_string())
.parse::<bool>()
.unwrap_or(false);
if side.ne(PROVIDER_SIDE) && !register_consumer {
warn!("Please set 'dubbo.registry.parameters.register-consumer-url=true' to turn on consumer url registration.");
return Ok(());
}
let nacos_service_name = NacosServiceName::new(&url);
let group_name = Some(
nacos_service_name
.get_group_with_default(DEFAULT_GROUP)
.to_string(),
);
let nacos_service_name = nacos_service_name.to_register_str();
let nacos_service_instance = Self::create_nacos_service_instance(url);
info!("register service: {}", nacos_service_name);
let ret = self.nacos_naming_service.register_instance(
nacos_service_name,
group_name,
nacos_service_instance,
);
if let Err(e) = ret {
error!("register to nacos occur an error: {:?}", e);
return Err(anyhow!("register to nacos occur an error: {:?}", e).into());
}
Ok(())
}