diff --git a/src/main/java/com/newyetai/mq/consumer/ConsumerDeliverer.java b/src/main/java/com/newyetai/mq/consumer/ConsumerDeliverer.java index d6ed9ba..9ed5dc9 100644 --- a/src/main/java/com/newyetai/mq/consumer/ConsumerDeliverer.java +++ b/src/main/java/com/newyetai/mq/consumer/ConsumerDeliverer.java @@ -88,6 +88,7 @@ public class ConsumerDeliverer implements ChannelAwareMessageListener { try { obj = jackson2JsonMessageConverter.fromMessage(message, getParameterizedTypeReference(routingKey, handler)); + log.info("mqDeliverer msg:{}", message); handler.onMessage((IMqMessage) obj); return; } catch (MessageConversionException e) {