From 4c8375e861bdee64f0c92c675d51ed5539d0bf03 Mon Sep 17 00:00:00 2001 From: Chopper Date: Mon, 5 Jul 2021 16:41:39 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B6=B3=E8=BF=B9=E8=AE=B0=E5=BD=95mq=E6=97=B6?= =?UTF-8?q?=EF=BC=8C=E5=8D=95=E5=90=91=E5=8F=91=E9=80=81=EF=BC=8C=E4=B8=8D?= =?UTF-8?q?=E7=AD=89=E5=BE=85mq=E5=93=8D=E5=BA=94?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/lili/modules/goods/serviceimpl/GoodsSkuServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/framework/src/main/java/cn/lili/modules/goods/serviceimpl/GoodsSkuServiceImpl.java b/framework/src/main/java/cn/lili/modules/goods/serviceimpl/GoodsSkuServiceImpl.java index 4f4446d5..ac9dad97 100644 --- a/framework/src/main/java/cn/lili/modules/goods/serviceimpl/GoodsSkuServiceImpl.java +++ b/framework/src/main/java/cn/lili/modules/goods/serviceimpl/GoodsSkuServiceImpl.java @@ -235,7 +235,7 @@ public class GoodsSkuServiceImpl extends ServiceImpl i if (UserContext.getCurrentUser() != null) { FootPrint footPrint = new FootPrint(UserContext.getCurrentUser().getId(), goodsId, skuId); String destination = rocketmqCustomProperties.getGoodsTopic() + ":" + GoodsTagsEnum.VIEW_GOODS.name(); - rocketMQTemplate.asyncSend(destination, footPrint, RocketmqSendCallbackBuilder.commonCallback()); + rocketMQTemplate.sendOneWay(destination, footPrint); } return map; }