Notification testing using cache

samagra-comms · May 11, 2023 · 154deed · 154deed
1 parent b9ad68e
commit 154deed
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java b/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java
@@ -52,6 +52,8 @@ public class OutboundKafkaController {
     @Value("${spring.mail.recipient}")
     private String recipient;
 
+    private static long count = 0;
+
     @EventListener(ApplicationStartedEvent.class)
     public void onMessage() {
         reactiveKafkaReceiver
@@ -125,6 +127,8 @@ public void accept(Throwable e) {
                                             @Override
                                             public void accept(XMessageDAO xMessageDAO) {
                                                 log.info("XMessage Object saved is with sent user ID >> " + xMessageDAO.getUserId());
+                                                count++;
+                                                log.info("Insert Record in Cass : "+count);
                                             }
                                         });
                             } catch (Exception e) {