add filters

xwm1992 · Nov 13, 2023 · d76cc61 · d76cc61
1 parent d077d0f
commit d76cc61
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 0 deletions.
diff --git a/...mesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/meta/MetaService.java b/...mesh-meta/eventmesh-meta-api/src/main/java/org/apache/eventmesh/api/meta/MetaService.java
@@ -71,4 +71,10 @@ default EventMeshAppSubTopicInfo findEventMeshAppSubTopicInfoByGroup(String grou
     default List<EventMeshServicePubTopicInfo> findEventMeshServicePubTopicInfos() throws MetaException {
         return Collections.emptyList();
     }
+
+    /**
+     * addListener
+     * @param metaServiceListener used for notify when config changed if needed
+     */
+    void addMetaServiceListener(MetaServiceListener<String, String> metaServiceListener);
 }
diff --git a/...meta-consul/src/main/java/org/apache/eventmesh/meta/consul/service/ConsulMetaService.java b/...meta-consul/src/main/java/org/apache/eventmesh/meta/consul/service/ConsulMetaService.java
@@ -19,6 +19,7 @@
 
 import org.apache.eventmesh.api.exception.MetaException;
 import org.apache.eventmesh.api.meta.MetaService;
+import org.apache.eventmesh.api.meta.MetaServiceListener;
 import org.apache.eventmesh.api.meta.dto.EventMeshDataInfo;
 import org.apache.eventmesh.api.meta.dto.EventMeshRegisterInfo;
 import org.apache.eventmesh.api.meta.dto.EventMeshUnRegisterInfo;
@@ -66,6 +67,8 @@ public class ConsulMetaService implements MetaService {
 
     private ConsulTLSConfig tlsConfig;
 
+    private MetaServiceListener<String, String> metaServiceListener;
+
     @Override
     public void init() throws MetaException {
         if (initStatus.compareAndSet(false, true)) {
@@ -162,6 +165,11 @@ public boolean unRegister(EventMeshUnRegisterInfo eventMeshUnRegisterInfo) throw
         return true;
     }
 
+    @Override
+    public void addMetaServiceListener(MetaServiceListener<String, String> metaServiceListener) {
+        this.metaServiceListener = metaServiceListener;
+    }
+
     @Override
     public List<EventMeshDataInfo> findEventMeshInfoByCluster(String clusterName) throws MetaException {
         HealthServicesRequest request = HealthServicesRequest.newBuilder().setPassing(true).setToken(token).build();

diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/meta/MetaStorage.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/meta/MetaStorage.java
@@ -19,6 +19,7 @@
 
 import org.apache.eventmesh.api.exception.MetaException;
 import org.apache.eventmesh.api.meta.MetaService;
+import org.apache.eventmesh.api.meta.MetaServiceListener;
 import org.apache.eventmesh.api.meta.bo.EventMeshAppSubTopicInfo;
 import org.apache.eventmesh.api.meta.bo.EventMeshServicePubTopicInfo;
 import org.apache.eventmesh.api.meta.dto.EventMeshDataInfo;
@@ -40,6 +41,8 @@ public class MetaStorage {
 
     private MetaService metaService;
 
+    private MetaServiceListener<String, String> metaServiceListener;
+
     private final AtomicBoolean inited = new AtomicBoolean(false);
 
     private final AtomicBoolean started = new AtomicBoolean(false);
@@ -128,4 +131,12 @@ public List<EventMeshServicePubTopicInfo> findEventMeshServicePubTopicInfos() th
     public EventMeshAppSubTopicInfo findEventMeshAppSubTopicInfo(String group) throws Exception {
         return metaService.findEventMeshAppSubTopicInfoByGroup(group);
     }
+
+    public MetaServiceListener<String, String> getMetaServiceListener() {
+        return metaServiceListener;
+    }
+
+    public void setMetaServiceListener(MetaServiceListener<String, String> metaServiceListener) {
+        this.metaServiceListener = metaServiceListener;
+    }
 }