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 6f6c6d1..3583caf 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 @@ -184,6 +184,7 @@ public class ImgMqMessageRecordServiceImpl implements ImgMqMessageRecordService imgMqMessageRecord.setCreateTime(new Date()); imgMqMessageRecord.setMessageKey(message.getMessageKey()); imgMqMessageRecord.setContent(JSON.toJSONString(message)); + imgMqMessageRecord.setReturnTopic(message.getReturnTopic()); imgMqMessageRecordMapper.insert(imgMqMessageRecord); return imgMqMessageRecord; } 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 28c1247..045355c 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 @@ -181,6 +181,7 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ orderMqMessageRecord.setCreateTime(new Date()); orderMqMessageRecord.setMessageKey(message.getMessageKey()); orderMqMessageRecord.setContent(JSON.toJSONString(message)); + orderMqMessageRecord.setReturnTopic(message.getReturnTopic()); orderMqMessageRecordMapper.insert(orderMqMessageRecord); return orderMqMessageRecord; } 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 73935c0..8aae29d 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 @@ -182,6 +182,7 @@ public class PayMqMessageRecordServiceImpl implements PayMqMessageRecordService payMqMessageRecord.setCreateTime(new Date()); payMqMessageRecord.setMessageKey(message.getMessageKey()); payMqMessageRecord.setContent(JSON.toJSONString(message)); + payMqMessageRecord.setReturnTopic(message.getReturnTopic()); payMqMessageRecordMapper.insert(payMqMessageRecord); return payMqMessageRecord; }