@ -81,6 +81,7 @@ public class MessageDispatcher<T extends TaoBaoMessage> implements MessageHandle
return true;
}
tradeMsg.setId(message.getId());
tradeMsg.setTopic(message.getTopic());
tradeMsg.setPubAppKey(message.getPubAppKey());