diff --git a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/hander/MessageDispatcher.java b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/hander/MessageDispatcher.java index 5b31261..50f0979 100644 --- a/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/hander/MessageDispatcher.java +++ b/service/trade-service-source/trade-service-source-taobao/src/main/java/com/hchbox/hander/MessageDispatcher.java @@ -81,6 +81,7 @@ public class MessageDispatcher implements MessageHandle return true; } + tradeMsg.setId(message.getId()); tradeMsg.setTopic(message.getTopic()); tradeMsg.setPubAppKey(message.getPubAppKey());