diff --git a/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java b/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java index fbb95e3..ea7434d 100644 --- a/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java +++ b/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java @@ -132,7 +132,9 @@ 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); - logTimeTaken(startTime, 0, "Insert Record in Cass : " + count +" ::: process-end: %d ms"); + if (provider.toLowerCase().equals("firebase") && channel.toLowerCase().equals("web")) { + logTimeTaken(startTime, 0, "Insert Record in Cass : " + count + " ::: process-end: %d ms"); + } } }); } catch (Exception e) {