changes

samagra-comms · Feb 4, 2022 · b866ac4 · b866ac4
1 parent 61a66d4
commit b866ac4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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