Merge pull request #42 from pankajjangid05/prod-development

Prod development
samagra-comms · May 26, 2023 · 537521d · 537521d
2 parents 6715f0e + 626c20f
commit 537521d
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java b/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java
@@ -50,7 +50,7 @@ public class OutboundKafkaController {
     @Value("${spring.mail.recipient}")
     private String recipient;
 
-    private static long count = 0;
+    private long notificationCount, otherCount;
 
     @EventListener(ApplicationStartedEvent.class)
     public void onMessage() {
@@ -128,10 +128,12 @@ 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);
-                                                if (provider.toLowerCase().equals("firebase") && channel.toLowerCase().equals("web")) {
-                                                    logTimeTaken(startTime, 0, "Insert Record in Cass : " + count + " ::: process-end: %d ms");
+                                                if(provider.toLowerCase().equals("firebase") && channel.toLowerCase().equals("web")){
+                                                    notificationCount++;
+                                                    logTimeTaken(startTime, 0, "Notification Insert Record in Cass : " + notificationCount +" ::: process-end: %d ms");
+                                                } else {
+                                                    otherCount++;
+                                                    logTimeTaken(startTime, 0, "Other Insert Record in Cass : " + otherCount +" ::: process-end: %d ms");
                                                 }
                                             }
                                         });