changes

goafabric · Jul 6, 2024 · 75af0b0 · 75af0b0
1 parent 9da7268
commit 75af0b0
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 74 deletions.
diff --git a/...cher/consumer/kafka/CalendarConsumer.java → ...dispatcher/consumer/CalendarConsumer.java b/...cher/consumer/kafka/CalendarConsumer.java → ...dispatcher/consumer/CalendarConsumer.java
@@ -1,4 +1,4 @@
-package org.goafabric.eventdispatcher.consumer.kafka;
+package org.goafabric.eventdispatcher.consumer;
 
 import org.goafabric.eventdispatcher.producer.EventData;
 import org.slf4j.Logger;
@@ -14,6 +14,11 @@ public class CalendarConsumer {
 
     static final String CONSUMER_NAME = "Calendar";
 
+    public CalendarConsumer(NatsSubscription natsSubscription) {
+        natsSubscription.create(CONSUMER_NAME, "patient.*", (msg, eventData) -> process(msg.getSubject(), eventData));
+        natsSubscription.create(CONSUMER_NAME, "practitioner.*", (msg, eventData) -> process(msg.getSubject(), eventData));
+    }
+
     @KafkaListener(groupId = CONSUMER_NAME, topics = {"patient", "practitioner"})
     public void processKafka(@Header(KafkaHeaders.RECEIVED_KEY) String key, EventData eventData) {
         process(key, eventData);

diff --git a/...atcher/consumer/kafka/LoggerConsumer.java → ...ntdispatcher/consumer/LoggerConsumer.java b/...atcher/consumer/kafka/LoggerConsumer.java → ...ntdispatcher/consumer/LoggerConsumer.java
@@ -1,4 +1,4 @@
-package org.goafabric.eventdispatcher.consumer.kafka;
+package org.goafabric.eventdispatcher.consumer;
 
 import org.goafabric.eventdispatcher.producer.EventData;
 import org.goafabric.eventdispatcher.service.extensions.TenantContext;
@@ -15,6 +15,10 @@ public class LoggerConsumer {
 
     static final String CONSUMER_NAME = "Logger";
 
+    public LoggerConsumer(NatsSubscription natsSubscription) {
+        natsSubscription.create(CONSUMER_NAME, "*.*", (msg, eventData) -> process(msg.getSubject(), eventData));
+    }
+
     @KafkaListener(groupId = CONSUMER_NAME, topicPattern = ".*")
     public void processKafka(@Header(KafkaHeaders.RECEIVED_KEY) String key, EventData eventData) {
         process(key, eventData);

diff --git a/...tcher/consumer/nats/NatsSubscription.java → ...dispatcher/consumer/NatsSubscription.java b/...tcher/consumer/nats/NatsSubscription.java → ...dispatcher/consumer/NatsSubscription.java
@@ -1,4 +1,4 @@
-package org.goafabric.eventdispatcher.consumer.nats;
+package org.goafabric.eventdispatcher.consumer;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.dataformat.cbor.CBORFactory;

diff --git a/src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsCalendarConsumer.java b/src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsCalendarConsumer.java
diff --git a/src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsLoggerConsumer.java b/src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsLoggerConsumer.java