diff --git a/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java b/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java index 3583caf..3aae260 100644 --- a/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java +++ b/bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java @@ -221,7 +221,7 @@ public class ImgMqMessageRecordServiceImpl implements ImgMqMessageRecordService message.setReturnTopic(imgMqMessageRecord.getReturnTopic()); message.setContent(msg); //少于30分钟,发送消息 - sendAsyncMsg(imgMqMessageRecord.getTopic(),null,message); + rocketMQEnhanceTemplate.sendAsyncMsg(imgMqMessageRecord.getTopic(),null,message); }else{ //超过30分钟,修改状态为废弃 imgMqMessageRecord.setStatus(EnumMessageStatus.INVALID); diff --git a/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java b/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java index 045355c..343244a 100644 --- a/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java +++ b/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java @@ -218,7 +218,7 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ message.setReturnTopic(orderMqMessageRecord.getReturnTopic()); message.setContent(msg); //少于30分钟,发送消息 - sendAsyncMsg(orderMqMessageRecord.getTopic(),null,message); + rocketMQEnhanceTemplate.sendAsyncMsg(orderMqMessageRecord.getTopic(),null,message); }else{ //超过30分钟,修改状态为废弃 orderMqMessageRecord.setStatus(EnumMessageStatus.INVALID); diff --git a/bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java b/bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java index 8aae29d..1fc6d71 100644 --- a/bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java +++ b/bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java @@ -219,7 +219,7 @@ public class PayMqMessageRecordServiceImpl implements PayMqMessageRecordService message.setReturnTopic(payMqMessageRecord.getReturnTopic()); message.setContent(msg); //少于30分钟,发送消息 - sendAsyncMsg(payMqMessageRecord.getTopic(),null,message); + rocketMQEnhanceTemplate.sendAsyncMsg(payMqMessageRecord.getTopic(),null,message); }else{ //超过30分钟,修改状态为废弃 payMqMessageRecord.setStatus(EnumMessageStatus.INVALID);