Adding logs before sending to orchestrator

samagra-comms · Apr 2, 2023 · ad14f7b · ad14f7b
1 parent 7166d7c
commit ad14f7b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/com/uci/transformer/generic/GenericTransformerConsumer.java b/src/main/java/com/uci/transformer/generic/GenericTransformerConsumer.java
@@ -91,6 +91,7 @@ else if (msg.getPayload().getText().equals(assesmentGotostart)) {
                 }
                 msg.setSessionId(UUID.randomUUID());
                 msg.setPayload(payload);
+                log.info("CP-01", msg.toXML());
                 kafkaProducer.send(processOutbound, msg.toXML());
             } else {
 
@@ -273,6 +274,7 @@ public Boolean apply(GenericMessageResponse response) {
                                 }
                                 msg.setPayload(payload);
                                 try {
+                                    log.info("CP-02", msg.toXML());
                                     kafkaProducer.send(processOutbound, msg.toXML());
                                 } catch (JAXBException e) {
                                     throw new RuntimeException(e);
@@ -302,6 +304,7 @@ private void sendWelcomeMessage(XMessagePayload payload, XMessage msg) throws JA
             payload.setMedia(messageMedia);
         }
         msg.setPayload(payload);
+        log.info("CP-03", msg.toXML());
         kafkaProducer.send(processOutbound, msg.toXML());
     }
 }