diff --git a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/mq/directive/listener/DirectiveMQListener.java b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/mq/directive/listener/DirectiveMQListener.java index cd0252d..779bcd3 100644 --- a/nursing-unit-services/nu-services-biz/src/main/java/com/nu/mq/directive/listener/DirectiveMQListener.java +++ b/nursing-unit-services/nu-services-biz/src/main/java/com/nu/mq/directive/listener/DirectiveMQListener.java @@ -48,7 +48,7 @@ public class DirectiveMQListener { * * @param dto */ - @RabbitListener(queues = "nu002.fwzl.async", errorHandler = "directiveMQErrorHandler") +// @RabbitListener(queues = "nu002.fwzl.async", errorHandler = "directiveMQErrorHandler") @DSTransactional(rollbackFor = {Exception.class}) public void handleMessage(DirectiveMQDto dto) { try {