fix[net]: fixed bug in client initialization registry

This commit is contained in:
luca committed 2024-05-31 14:16:04 +08:00
1 parent f2dfb1433a
commit 730929fbf1
1 file changed
+8 -7
@@ -85,17 +85,18 @@ public class ConfigManager implements IConfigManager {
// 接下来就是通过注册中心,把生产者和消费者关联起来 // 接下来就是通过注册中心,把生产者和消费者关联起来
try { try {
var registryConfig = NetContext.getConfigManager().getLocalConfig().getRegistry(); var registryConfig = NetContext.getConfigManager().getLocalConfig().getRegistry();
String driverClassName = registryConfig.getDriverClassName(); if (registryConfig != null) {
if (driverClassName == null || driverClassName.isBlank()){ String driverClassName = registryConfig.getDriverClassName();
registry = new ZookeeperRegistry(); if (driverClassName == null || driverClassName.isBlank()){
} else { registry = new ZookeeperRegistry();
registry = (IRegistry) Class.forName(driverClassName).getDeclaredConstructor().newInstance(); } else {
registry = (IRegistry) Class.forName(driverClassName).getDeclaredConstructor().newInstance();
}
registry.start();
} }
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException("registry instance err", e); throw new RuntimeException("registry instance err", e);
} }
registry.start();
} }
@Override @Override