feature:fixbug

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);

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);

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);