From d72a7a641e90d9537982982abdc55982a0f9f59b Mon Sep 17 00:00:00 2001 From: wuxicheng <1441859745@qq.com> Date: Sun, 21 May 2023 00:27:23 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9E=E7=8E=B0=E6=9C=AC=E5=9C=B0=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E8=A1=A8=E6=B6=88=E6=81=AF=E8=A1=A5=E5=81=BF=EF=BC=8C?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E5=8E=BB=E9=87=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../order/service/impl/OrderMqMessageRecordServiceImpl.java | 1 - 1 file changed, 1 deletion(-) 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 73c9241..a2c3f8a 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 @@ -83,7 +83,6 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ OrderMqMessageRecord orderMqMessageRecord = saveMessageRecord(topic,tag, message); //发消息 OrderMqLocalRecordMessage mqLocalMessage = EntityConvertUtil.copy(orderMqMessageRecord, OrderMqLocalRecordMessage.class); - mqLocalMessage.setRetryTimes(0); mqLocalMessage.setSource(ServiceNameConstants.ORDER_SERVICE); rocketMQTemplate.asyncSend(rocketMQEnhanceTemplate.buildDestination(topic,tag), MessageBuilder.withPayload(mqLocalMessage).build(), new SendCallback() { @Override