bug处理

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 <T> 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;
     }
 

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 <T> 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;
     }
 

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 <T> 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;
     }