消息表增加返回主题

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

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

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