Merge branch 'dev'

123

themis-business/src/main/java/com/qmth/themis/business/service/impl/ProducerServerImpl.java

@@ -138,8 +138,8 @@ public class ProducerServerImpl implements ProducerServer {
     @Override
     public Result asyncDelayMsg(MqDto mqDto) {
         log.info("asyncDelayMsg mqDto:{}", JacksonUtil.parseJson(mqDto));
-//        Message message = assembleMessage(mqDto);
-        org.springframework.messaging.Message messageTran = MessageBuilder.withPayload(mqDto).build();
+        Message message = assembleMessage(mqDto);
+        org.springframework.messaging.Message messageTran = MessageBuilder.withPayload(message).build();
         rocketMQTemplate.asyncSend(mqDto.getTopic() + ":" + mqDto.getTag(), messageTran, new SendCallback() {
             @Override
             public void onSuccess(SendResult sendResult) {