changes

src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsCalendarConsumer.java

@@ -13,11 +13,11 @@ public class NatsCalendarConsumer {
     private static final String CONSUMER_NAME = "Calendar";
 
 
-    public NatsCalendarConsumer(ConsumerUtil consumerUtil) {
-        consumerUtil.subscribe(CONSUMER_NAME, "patient.*",
+    public NatsCalendarConsumer(NatsSubscription natsSubscription) {
+        natsSubscription.create(CONSUMER_NAME, "patient.*",
                 (msg, eventData) -> process(msg.getSubject(), eventData));
 
-        consumerUtil.subscribe(CONSUMER_NAME, "practitioner.*",
+        natsSubscription.create(CONSUMER_NAME, "practitioner.*",
                 (msg, eventData) -> process(msg.getSubject(), eventData));
     }
 

src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsLoggerConsumer.java

@@ -12,8 +12,8 @@ public class NatsLoggerConsumer {
     private final Logger log = LoggerFactory.getLogger(this.getClass());
     private static final String CONSUMER_NAME = "Logger";
 
-    public NatsLoggerConsumer(ConsumerUtil consumerUtil) {
-        consumerUtil.subscribe(CONSUMER_NAME, "*.*",
+    public NatsLoggerConsumer(NatsSubscription natsSubscription) {
+        natsSubscription.create(CONSUMER_NAME, "*.*",
                 (msg, eventData) -> process(msg.getSubject(), eventData));
     }
 

src/main/java/org/goafabric/eventdispatcher/consumer/nats/ConsumerUtil.java → src/main/java/org/goafabric/eventdispatcher/consumer/nats/NatsSubscription.java

@@ -13,18 +13,18 @@
 
 
 @Component
-public class ConsumerUtil {
+public class NatsSubscription {
     private final Connection natsConnection;
     private final ObjectMapper objectMapper;
 
-    public ConsumerUtil(Connection natsConnection) {
+    public NatsSubscription(Connection natsConnection) {
         this.natsConnection = natsConnection;
         this.objectMapper = new ObjectMapper(new CBORFactory()); //binary serializer for performance
     }
 
     //creates a durable consumer which msg being delivered even if consumer is not running,
     //autoAck will automatically remove from queue when delivered, when renaming the consumer, it will just create a new one !
-    public void subscribe(String consumerName, String subject, EventMessageHandler handler ) {
+    public void create(String consumerName, String subject, EventMessageHandler handler ) {
         try {
             natsConnection.jetStream().subscribe(subject, natsConnection.createDispatcher(),
                     msg -> handler.onMessage(msg, getEvent(msg.getData())),