tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-08-21 08:27:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #107 from LucaLq/main

Browse Source 
fix[net]: fixed bug in client initialization registry
This commit is contained in:
godotg
2024-05-31 16:40:18 +08:00
committed by GitHub
parent f2dfb1433a 7a97238496
commit 579e2af405
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
net/src/main/java/com/zfoo/net/config/ConfigManager.java
+9 -6
View File
@@ -85,17 +85,20 @@ public class ConfigManager implements IConfigManager {
// 接下来就是通过注册中心，把生产者和消费者关联起来
try {
var registryConfig = NetContext.getConfigManager().getLocalConfig().getRegistry();
String driverClassName = registryConfig.getDriverClassName();
if (driverClassName == null || driverClassName.isBlank()){
registry = new ZookeeperRegistry();
if (registryConfig != null) {
String driverClassName = registryConfig.getDriverClassName();
if (driverClassName == null || driverClassName.isBlank()){
registry = new ZookeeperRegistry();
} else {
registry = (IRegistry) Class.forName(driverClassName).getDeclaredConstructor().newInstance();
}
} else {
registry = (IRegistry) Class.forName(driverClassName).getDeclaredConstructor().newInstance();
registry = new ZookeeperRegistry();
}
registry.start();
} catch (Exception e) {
throw new RuntimeException("registry instance err", e);
}
registry.start();
}
@Override