Merge branch 'main' of github.com:larsid/soft-iot-dlt-client-tangle-h…

…ornet into main
larsid · Feb 10, 2025 · b7ac0ab · b7ac0ab
2 parents aeb70c9 + 5169457
commit b7ac0ab
Showing 1 changed file with 23 additions and 5 deletions.
diff --git a/src/main/java/dlt/client/tangle/hornet/model/LedgerReader.java b/src/main/java/dlt/client/tangle/hornet/model/LedgerReader.java
@@ -226,12 +226,30 @@ public void run() {
   }
 
   private void notifyAll(String topic, Object object, Object object2) {
-    if (topic != null && !topic.isEmpty()) {
-      Set<ILedgerSubscriber> subscribers = this.topics.get(topic);
-      if (subscribers != null && !subscribers.isEmpty()) {
-        subscribers.forEach(sub -> sub.update(object, object2));
+      if (topic == null || topic.isEmpty()) {
+          return;
       }
-    }
+      Set<ILedgerSubscriber> subscribers = this.getSubscribers(topic);
+      if (subscribers == null || subscribers.isEmpty()) {
+          return;
+      }
+      subscribers.forEach(sub -> sub.update(object, object2));
+  }
+
+  private Set<ILedgerSubscriber> getSubscribers(String topic) {
+      Set<ILedgerSubscriber> subscribers = new HashSet<>();
+
+      if (topics.containsKey(topic)) {
+          subscribers.addAll(topics.get(topic));
+      }
+
+      for (Map.Entry<String, Set<ILedgerSubscriber>> entry : topics.entrySet()) {
+          String registeredTopic = entry.getKey();
+          if (registeredTopic.matches(topic.replace("*", ".*"))) {
+              subscribers.addAll(entry.getValue());
+          }
+      }
+      return subscribers;
   }
 
   public String getUrlApi() {