support enabled registry plugin

xwm1992 · May 23, 2024 · d971f1f · d971f1f
1 parent b3ac90b
commit d971f1f
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 9 deletions.
diff --git a/eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/AdminServer.java b/eventmesh-admin-server/src/main/java/com/apache/eventmesh/admin/server/AdminServer.java
@@ -76,22 +76,28 @@ public void reportHeartbeat(ReportHeartBeatRequest heartBeat) {
     @Override
     @PostConstruct
     public void start() {
-
-        registryService.init();
+        if (configuration.isEventMeshRegistryPluginEnabled()) {
+            registryService.init();
+        }
     }
 
     @Override
     public void destroy() {
-        registryService.unRegister(adminServeInfo);
-        try {
-            Thread.sleep(3000);
-        }catch (InterruptedException ignore){}
-        registryService.shutdown();
+        if (configuration.isEventMeshRegistryPluginEnabled()) {
+            registryService.unRegister(adminServeInfo);
+            try {
+                Thread.sleep(3000);
+            } catch (InterruptedException ignore) {
+            }
+            registryService.shutdown();
+        }
     }
 
     @Override
     public void onApplicationEvent(ApplicationReadyEvent event) {
-        log.info("application is started, it's will register admin self");
-        registryService.register(adminServeInfo);
+        if (configuration.isEventMeshRegistryPluginEnabled()) {
+            log.info("application is started and registry plugin is enabled, it's will register admin self");
+            registryService.register(adminServeInfo);
+        }
     }
 }
diff --git a/eventmesh-common/src/main/java/org/apache/eventmesh/common/config/CommonConfiguration.java b/eventmesh-common/src/main/java/org/apache/eventmesh/common/config/CommonConfiguration.java
@@ -115,6 +115,9 @@ public class CommonConfiguration {
     @ConfigField(field = "registry.plugin.password")
     private String eventMeshRegistryPluginPassword = "";
 
+    @ConfigField(field = "registry.plugin.enabled")
+    private boolean eventMeshRegistryPluginEnabled = false;
+
     public void reload() {
         this.eventMeshWebhookOrigin = "eventmesh." + eventMeshIDC;