diff --git a/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java b/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java index fbb95e3..ec7c040 100644 --- a/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java +++ b/src/main/java/com/uci/outbound/consumers/OutboundKafkaController.java @@ -22,10 +22,8 @@ import reactor.core.publisher.Flux; import reactor.kafka.receiver.ReceiverRecord; -import javax.xml.bind.JAXBException; import java.io.ByteArrayInputStream; import java.util.HashMap; -import java.util.Map; import java.util.function.Consumer; @Component @@ -144,10 +142,8 @@ public void accept(XMessageDAO xMessageDAO) { try { log.error("The current XMessage was : " + xMessage.toString()); } catch (Exception ge) { - ge.printStackTrace(); log.error("Unable to parse the current XMessage : " + ge.getMessage() + " Xmessage : " + ge.getMessage()); } - e.printStackTrace(); } } else { log.info("XMessage -> app is empty");