[Hot Fix] - Added log for cassandra insert count

samagra-comms · May 16, 2023 · 6a6914b · 6a6914b
1 parent e409eee
commit 6a6914b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/com/uci/inbound/incoming/CampaignController.java b/src/main/java/com/uci/inbound/incoming/CampaignController.java
@@ -54,6 +54,7 @@ public class CampaignController {
     String topicFailure;
 
     private long cassInsertCount;
+    private long cassInsertErrorCount;
 
     @RequestMapping(value = "/start", method = RequestMethod.GET)
     public ResponseEntity<String> startCampaign(@RequestParam("campaignId") String campaignId, @RequestParam(value = "page", required = false) String page) throws JsonProcessingException, JAXBException {
@@ -125,7 +126,9 @@ private void sendEventToKafka(XMessage xmsg) {
     }
 
     private Consumer<Throwable> genericError(String s) {
+        cassInsertErrorCount++;
         return c -> {
+            log.info("Data not inserted in Cassandra Count : " + cassInsertErrorCount);
             log.error(s + "::" + c.getMessage());
         };
     }