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 bc90114..cfe36ad 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 159e628..0a30a4d 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 @@ -182,6 +182,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 331a8cb..9f5e108 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 @@ -183,6 +183,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; }