调整示例rocketmq

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

 package com.secoo.rocketmq;
 
 import com.secoo.rocketmq.bean.User;
+import org.apache.rocketmq.client.producer.SendResult;
 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;
 
@@ -16,7 +18,7 @@ public class RoketMqSampleApplication implements ApplicationRunner {
     @Resource
     private RocketMQTemplate template;
 
-    private String topicName = "roketmq-simple-springboot";
+    private String topicName= "roketmq-simple-springboot";
 
     public static void main(String[] args) {
         new SpringApplicationBuilder(RoketMqSampleApplication.class).run(args);
@@ -27,8 +29,8 @@ public class RoketMqSampleApplication implements ApplicationRunner {
         User user = new User();
         user.setId(1L);
         user.setName("zhangsan");
-        String createTagName = ":create";
-        String createTagName2 = ":create2";
+        String destination2 = topicName+":create2";
+        String destination3 = topicName+":createTagName3";
 
         //1.没有指定tag，单项发送消息
         template.sendOneWay(topicName, user);
@@ -38,7 +40,8 @@ public class RoketMqSampleApplication implements ApplicationRunner {
         //2.指定tag，并同步发送消息
         //指定tag为create发送到topic。topic和name之间用“：”分割
 
-        template.syncSend(topicName + createTagName2, user, 10000);
+        template.syncSend(destination2, user, 10000);
 
+         
     }
 }
\ No newline at end of file