bean

goafabric · Jul 5, 2024 · 8463d78 · 8463d78
1 parent ef331f2
commit 8463d78
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsCalendarConsumer.java b/src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsCalendarConsumer.java
@@ -13,15 +13,19 @@ public class NatsCalendarConsumer {
     private static final String CONSUMER_NAME = "Calendar";
 
 
+    /*
     public NatsCalendarConsumer(ConsumerUtil consumerUtil) {
         consumerUtil.subscribe(CONSUMER_NAME, "patient.*",
                 (msg, eventData) -> process(msg.getSubject(), eventData));
 
         consumerUtil.subscribe(CONSUMER_NAME, "practitioner.*",
                 (msg, eventData) -> process(msg.getSubject(), eventData));
     }
+     */
 
-    private void process(String key, EventData eventData) {
+    @NatsListener(consumerName = CONSUMER_NAME, subject = "patient.*")
+    //@NatsListener(consumerName = CONSUMER_NAME, subject = "patient.*")
+    public void process(String key, EventData eventData) {
         switch (key) {
             case "patient.create" -> createPatient(eventData.referenceId());
             case "patient.update" -> updatePatient(eventData.referenceId());