in ons-core/ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ONSClientAbstract.java [184:206]
protected String getNamespace() {
String namespace = null;
{
String nameserverAddr = this.properties.getProperty(PropertyKeyConst.NAMESRV_ADDR);
if (StringUtils.isNotEmpty(nameserverAddr)) {
if (NameAddrUtils.validateInstanceEndpoint(nameserverAddr)) {
namespace = NameAddrUtils.parseInstanceIdFromEndpoint(nameserverAddr);
LOGGER.info("User specify namespace by endpoint: {}.", namespace);
}
}
}
{
String namespaceFromProperty = this.properties.getProperty(PropertyKeyConst.INSTANCE_ID, null);
if (StringUtils.isNotEmpty(namespaceFromProperty)) {
namespace = namespaceFromProperty;
LOGGER.info("User specify namespace by property: {}.", namespace);
}
}
return namespace;
}