fix checkStyle error

apache · Jun 28, 2024 · fe8ac76 · fe8ac76
1 parent 2929b2f
commit fe8ac76
Showing 1 changed file with 25 additions and 25 deletions.
diff --git a/eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/boot/RuntimeInstance.java b/eventmesh-runtime-v2/src/main/java/org/apache/eventmesh/runtime/boot/RuntimeInstance.java
@@ -45,7 +45,7 @@ public class RuntimeInstance {
 
     private Map<String, RegisterServerInfo> adminServerInfoMap = new HashMap<>();
 
-//    private final RegistryService registryService;
+    private final RegistryService registryService;
 
     private Runtime runtime;
 
@@ -57,20 +57,20 @@ public class RuntimeInstance {
 
     public RuntimeInstance(RuntimeInstanceConfig runtimeInstanceConfig) {
         this.runtimeInstanceConfig = runtimeInstanceConfig;
-//        this.registryService = RegistryFactory.getInstance(runtimeInstanceConfig.getRegistryPluginType());
+        this.registryService = RegistryFactory.getInstance(runtimeInstanceConfig.getRegistryPluginType());
     }
 
     public void init() throws Exception {
-//        registryService.init();
-//        QueryInstances queryInstances = new QueryInstances();
-//        queryInstances.setServiceName(runtimeInstanceConfig.getAdminServiceName());
-//        queryInstances.setHealth(true);
-//        List<RegisterServerInfo> adminServerRegisterInfoList = registryService.selectInstances(queryInstances);
-//        if (!adminServerRegisterInfoList.isEmpty()) {
-//            adminServerAddr = getRandomAdminServerAddr(adminServerRegisterInfoList);
-//        } else {
-//            throw new RuntimeException("admin server address is empty, please check");
-//        }
+        registryService.init();
+        QueryInstances queryInstances = new QueryInstances();
+        queryInstances.setServiceName(runtimeInstanceConfig.getAdminServiceName());
+        queryInstances.setHealth(true);
+        List<RegisterServerInfo> adminServerRegisterInfoList = registryService.selectInstances(queryInstances);
+        if (!adminServerRegisterInfoList.isEmpty()) {
+            adminServerAddr = getRandomAdminServerAddr(adminServerRegisterInfoList);
+        } else {
+            throw new RuntimeException("admin server address is empty, please check");
+        }
         runtimeInstanceConfig.setAdminServerAddr(adminServerAddr);
         runtimeFactory = initRuntimeFactory(runtimeInstanceConfig);
         runtime = runtimeFactory.createRuntime(runtimeInstanceConfig);
@@ -80,19 +80,19 @@ public void init() throws Exception {
     public void start() throws Exception {
         if (!StringUtils.isBlank(adminServerAddr)) {
 
-//            registryService.subscribe((event) -> {
-//                log.info("runtime receive registry event: {}", event);
-//                List<RegisterServerInfo> registerServerInfoList = event.getInstances();
-//                Map<String, RegisterServerInfo> registerServerInfoMap = new HashMap<>();
-//                for (RegisterServerInfo registerServerInfo : registerServerInfoList) {
-//                    registerServerInfoMap.put(registerServerInfo.getAddress(), registerServerInfo);
-//                }
-//                if (!registerServerInfoMap.isEmpty()) {
-//                    adminServerInfoMap = registerServerInfoMap;
-//                    updateAdminServerAddr();
-//                }
-//
-//            }, runtimeInstanceConfig.getAdminServiceName());
+            registryService.subscribe((event) -> {
+                log.info("runtime receive registry event: {}", event);
+                List<RegisterServerInfo> registerServerInfoList = event.getInstances();
+                Map<String, RegisterServerInfo> registerServerInfoMap = new HashMap<>();
+                for (RegisterServerInfo registerServerInfo : registerServerInfoList) {
+                    registerServerInfoMap.put(registerServerInfo.getAddress(), registerServerInfo);
+                }
+                if (!registerServerInfoMap.isEmpty()) {
+                    adminServerInfoMap = registerServerInfoMap;
+                    updateAdminServerAddr();
+                }
+
+            }, runtimeInstanceConfig.getAdminServiceName());
             runtime.start();
             isStarted = true;
         } else {