This commit is contained in:
ran.shang
2025-08-26 11:41:38 +08:00
parent 8cbfd5aacd
commit bd2475a5e2

View File

@@ -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) {