From b866ac4ae87f5aca3be448bb3c5e140d591e2f4c Mon Sep 17 00:00:00 2001
From: Surabhi <surabhi.mahawar@aurigait.com>
Date: Fri, 4 Feb 2022 15:54:26 +0530
Subject: [PATCH] changes

---
 .../java/com/uci/orchestrator/Consumer/ReactiveConsumer.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/com/uci/orchestrator/Consumer/ReactiveConsumer.java b/src/main/java/com/uci/orchestrator/Consumer/ReactiveConsumer.java
index a69a1ad..1bb5dbd 100644
--- a/src/main/java/com/uci/orchestrator/Consumer/ReactiveConsumer.java
+++ b/src/main/java/com/uci/orchestrator/Consumer/ReactiveConsumer.java
@@ -109,6 +109,7 @@ public class ReactiveConsumer {
     
     @EventListener(ApplicationStartedEvent.class)
     public void onMessage() {
+    	
         reactiveKafkaReceiver
                 .doOnNext(new Consumer<ReceiverRecord<String, String>>() {
                     @Override