rocketmq-spring

whatsmars-mq/whatsmars-mq-rocketmq-spring/src/test/java/org/hongxi/whatsmars/rocketmq/spring/demo/Consumer.java

@@ -7,7 +7,7 @@ import org.springframework.context.support.ClassPathXmlApplicationContext;
  */
 public class Consumer {
     public static void main(String[] args) {
-        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("rocketmq-consumer.xml");
+        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("mq-consumer.xml");
         context.registerShutdownHook();
     }
 }

whatsmars-mq/whatsmars-mq-rocketmq-spring/src/test/java/org/hongxi/whatsmars/rocketmq/spring/demo/Producer.java

@@ -10,11 +10,11 @@ import org.springframework.context.support.ClassPathXmlApplicationContext;
 public class Producer {
 
     public static void main(String[] args) {
-        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("rocketmq-producer.xml");
+        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("mq-producer.xml");
         RocketMQTemplate rocketMQTemplate = (RocketMQTemplate) context.getBean("rocketMQTemplate");
         for (int i = 0; i < 20; i++) {
             try {
-                SendResult sendResult = rocketMQTemplate.send("sdk-test", "rocketMQTemplate");
+                SendResult sendResult = rocketMQTemplate.send("ROCKETMQ_SPRING_TEST", "rocketMQTemplate");
                 System.out.println(sendResult);
             } catch (Exception e) {
                 e.printStackTrace();