调整示例rocketmq

matrix-sample-rocketmq/matrix-sample-rocketmq-springboot/src/main/java/com/secoo/rocketmq/RoketMqSampleApplication.java

 package com.secoo.rocketmq;
 
-import com.secoo.mall.common.util.json.FastJsonUtil;
 import com.secoo.rocketmq.bean.User;
-import org.apache.rocketmq.common.message.MessageExt;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
-import org.springframework.messaging.support.MessageBuilder;
 
 import javax.annotation.Resource;
 
@@ -36,13 +33,10 @@ public class RoketMqSampleApplication implements ApplicationRunner {
         /* 注意：org.springframework.messaging.Message为默认对象，此对象是spring对所有消息体的抽象，
          *  而MessageExt为RoketMq自身对象，包含更细节信息，如msgId
          * */
-        MessageExt msg = new MessageExt();
-        //指定具有业务含义的msgId
-        msg.setMsgId(user.getId().toString());
-        msg.setBody(FastJsonUtil.toString(user).getBytes());
         //2.指定tag，并同步发送消息
-        //指定tag为create发送到topic 
-        template.syncSend(  topicName + createTagName,  msg);
+        //指定tag为create发送到topic
+
+        template.syncSend(topicName + createTagName, user, 10000);
 
     }
 }
\ No newline at end of file