From 455679b591d09327a501877045567c5ab75afefe Mon Sep 17 00:00:00 2001 From: wuxicheng <1441859745@qq.com> Date: Mon, 22 May 2023 10:30:51 +0800 Subject: [PATCH] =?UTF-8?q?bug=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java | 3 ++- .../order/service/impl/OrderMqMessageRecordServiceImpl.java | 3 ++- .../bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java | 3 ++- 3 files changed, 6 insertions(+), 3 deletions(-) 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 bb8de81..28173e7 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 @@ -66,6 +66,7 @@ public class ImgMqMessageRecordServiceImpl implements ImgMqMessageRecordService @NotNull private MqRecordMessage getMqRecordMessage(String topic, String tag, T message) { String buildTopic = rocketMQEnhanceTemplate.reBuildTopic(topic); + String buildReturnTopic = rocketMQEnhanceTemplate.reBuildTopic(RocketMqTopic.IMG_RETURN_MSG_TOPIC); MqRecordMessage mqRecordMessage = new MqRecordMessage(); mqRecordMessage.setTopic(buildTopic); mqRecordMessage.setTag(tag); @@ -73,7 +74,7 @@ public class ImgMqMessageRecordServiceImpl implements ImgMqMessageRecordService mqRecordMessage.setMessageKey(RocketMqRepeatConstant.MESSAGE_ID_PREFIX_IMG + IdUtil.getSnowflakeNextIdStr()); mqRecordMessage.setContent(JSON.toJSONString(message)); mqRecordMessage.setSource(applicationName); - mqRecordMessage.setReturnTopic(RocketMqTopic.IMG_RETURN_MSG_TOPIC); + mqRecordMessage.setReturnTopic(buildReturnTopic); return mqRecordMessage; } 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 6664fd5..bbe1ccb 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 @@ -65,6 +65,7 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ @NotNull private MqRecordMessage getMqRecordMessage(String topic, String tag, T message) { String buildTopic = rocketMQEnhanceTemplate.reBuildTopic(topic); + String buildReturnTopic = rocketMQEnhanceTemplate.reBuildTopic(RocketMqTopic.ORDER_RETURN_MSG_TOPIC); MqRecordMessage mqRecordMessage = new MqRecordMessage(); mqRecordMessage.setTopic(buildTopic); mqRecordMessage.setTag(tag); @@ -72,7 +73,7 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ mqRecordMessage.setMessageKey(RocketMqRepeatConstant.MESSAGE_ID_PREFIX_ORDER + IdUtil.getSnowflakeNextIdStr()); mqRecordMessage.setContent(JSON.toJSONString(message)); mqRecordMessage.setSource(applicationName); - mqRecordMessage.setReturnTopic(RocketMqTopic.ORDER_RETURN_MSG_TOPIC); + mqRecordMessage.setReturnTopic(buildReturnTopic); return mqRecordMessage; } 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 a00c876..949c5be 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 @@ -66,6 +66,7 @@ public class PayMqMessageRecordServiceImpl implements PayMqMessageRecordService @NotNull private MqRecordMessage getMqRecordMessage(String topic, String tag, T message) { String buildTopic = rocketMQEnhanceTemplate.reBuildTopic(topic); + String buildReturnTopic = rocketMQEnhanceTemplate.reBuildTopic(RocketMqTopic.PAY_RETURN_MSG_TOPIC); MqRecordMessage mqRecordMessage = new MqRecordMessage(); mqRecordMessage.setTopic(buildTopic); mqRecordMessage.setTag(tag); @@ -73,7 +74,7 @@ public class PayMqMessageRecordServiceImpl implements PayMqMessageRecordService mqRecordMessage.setMessageKey(RocketMqRepeatConstant.MESSAGE_ID_PREFIX_PAY + IdUtil.getSnowflakeNextIdStr()); mqRecordMessage.setContent(JSON.toJSONString(message)); mqRecordMessage.setSource(applicationName); - mqRecordMessage.setReturnTopic(RocketMqTopic.PAY_RETURN_MSG_TOPIC); + mqRecordMessage.setReturnTopic(buildReturnTopic); return mqRecordMessage; }