From 0fc2d1bf0ff16526732b1d14eccb055db7b7e154 Mon Sep 17 00:00:00 2001
From: = <=>
Date: Sun, 24 Dec 2017 13:30:32 +0800
Subject: [PATCH] update rocketmq starter example

---
 spring-boot-rocketmq/pom.xml                  | 10 ++---
 .../mq/DemoRocketMqConsumerExample.java       | 14 ++++---
 .../rocketmq/mq/DemoRocketMqContent.java      |  3 +-
 .../mq/DemoRocketMqProducerExample.java       | 37 +++++++++++++++++++
 .../rocketmq/mq/DemoRocketMqTag.java          |  2 +-
 .../rocketmq/mq/DemoRocketMqTopic.java        |  2 +-
 .../rocketmq/other/DemoRocketMqConsumer.java  | 36 ------------------
 .../src/main/resources/application.properties |  2 +-
 8 files changed, 56 insertions(+), 50 deletions(-)
 create mode 100644 spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqProducerExample.java
 delete mode 100644 spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/other/DemoRocketMqConsumer.java

diff --git a/spring-boot-rocketmq/pom.xml b/spring-boot-rocketmq/pom.xml
index f00475b..e0f34b7 100644
--- a/spring-boot-rocketmq/pom.xml
+++ b/spring-boot-rocketmq/pom.xml
@@ -18,15 +18,15 @@
         </dependency>
 
         <dependency>
-            <groupId>com.rhwayfun</groupId>
+            <groupId>io.github.rhwayfun</groupId>
             <artifactId>spring-boot-rocketmq-starter</artifactId>
-            <version>0.0.1-SNAPSHOT</version>
+            <version>0.0.3.RELEASE</version>
         </dependency>
 
         <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-test</artifactId>
-            <scope>test</scope>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.12</version>
         </dependency>
     </dependencies>
 
diff --git a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqConsumerExample.java b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqConsumerExample.java
index 58540ea..e520136 100644
--- a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqConsumerExample.java
+++ b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqConsumerExample.java
@@ -1,6 +1,6 @@
 package com.rhwayfun.springboot.rocketmq.mq;
 
-import com.rhwayfun.springboot.rocketmq.starter.common.AbstractRocketMqConsumer;
+import io.github.rhwayfun.springboot.rocketmq.starter.common.AbstractRocketMqConsumer;
 import org.apache.rocketmq.common.message.MessageExt;
 import org.springframework.stereotype.Component;
 
@@ -15,7 +15,7 @@
  */
 @Component
 public class DemoRocketMqConsumerExample
-        extends AbstractRocketMqConsumer<DemoRocketMqTopic, DemoRocketMqTag, DemoRocketMqContent> {
+        extends AbstractRocketMqConsumer<DemoRocketMqTopic, DemoRocketMqContent> {
 
     @Override
     public Map<String, Set<String>> subscribeTopicTags() {
@@ -28,9 +28,13 @@ public Map<String, Set<String>> subscribeTopicTags() {
     }
 
     @Override
-    public boolean handle(String topic, String tag, DemoRocketMqContent content, MessageExt msg) {
-        logger.info("receive msg[{}], topic:{}, tag:{}, content:{}", msg, topic, tag, content);
-        return true;
+    public String getConsumerGroup() {
+        return "spring-boot-test-consumer-group";
     }
 
+    @Override
+    public boolean consumeMsg(DemoRocketMqContent content, MessageExt msg) {
+        logger.info("receive msg[{}], topic:{}, tag:{}, content:{}", msg, content);
+        return false;
+    }
 }
diff --git a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqContent.java b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqContent.java
index def5ce9..88178cd 100644
--- a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqContent.java
+++ b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqContent.java
@@ -1,6 +1,7 @@
 package com.rhwayfun.springboot.rocketmq.mq;
 
-import com.rhwayfun.springboot.rocketmq.starter.constants.RocketMqContent;
+
+import io.github.rhwayfun.springboot.rocketmq.starter.constants.RocketMqContent;
 
 /**
  * @author rhwayfun
diff --git a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqProducerExample.java b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqProducerExample.java
new file mode 100644
index 0000000..80c3d82
--- /dev/null
+++ b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqProducerExample.java
@@ -0,0 +1,37 @@
+package com.rhwayfun.springboot.rocketmq.mq;
+
+import io.github.rhwayfun.springboot.rocketmq.starter.common.DefaultRocketMqProducer;
+import org.apache.rocketmq.common.message.Message;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.util.Timer;
+import java.util.TimerTask;
+
+/**
+ * @author rhwayfun
+ * @since 0.0.1
+ */
+@Component
+public class DemoRocketMqProducerExample {
+
+    @Resource
+    private DefaultRocketMqProducer producer;
+
+    @PostConstruct
+    public void execute() {
+        new Timer().schedule(new TimerTask() {
+            @Override
+            public void run() {
+                DemoRocketMqContent content = new DemoRocketMqContent();
+                content.setCityId(1);
+                content.setDesc("城市");
+                Message msg = new Message("TopicA", "TagA", content.toString().getBytes());
+                boolean sendResult = producer.sendMsg(msg);
+                System.out.println("发送结果：" + sendResult);
+            }
+        }, 0, 10000);
+    }
+
+}
diff --git a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqTag.java b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqTag.java
index d57a11b..9530785 100644
--- a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqTag.java
+++ b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqTag.java
@@ -1,6 +1,6 @@
 package com.rhwayfun.springboot.rocketmq.mq;
 
-import com.rhwayfun.springboot.rocketmq.starter.constants.RocketMqTag;
+import io.github.rhwayfun.springboot.rocketmq.starter.constants.RocketMqTag;
 
 /**
  * @author rhwayfun
diff --git a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqTopic.java b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqTopic.java
index fe7a094..392ed41 100644
--- a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqTopic.java
+++ b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/mq/DemoRocketMqTopic.java
@@ -1,6 +1,6 @@
 package com.rhwayfun.springboot.rocketmq.mq;
 
-import com.rhwayfun.springboot.rocketmq.starter.constants.RocketMqTopic;
+import io.github.rhwayfun.springboot.rocketmq.starter.constants.RocketMqTopic;
 
 /**
  * @author rhwayfun
diff --git a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/other/DemoRocketMqConsumer.java b/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/other/DemoRocketMqConsumer.java
deleted file mode 100644
index 2d409b6..0000000
--- a/spring-boot-rocketmq/src/main/java/com/rhwayfun/springboot/rocketmq/other/DemoRocketMqConsumer.java
+++ /dev/null
@@ -1,36 +0,0 @@
-package com.rhwayfun.springboot.rocketmq.other;
-
-import com.rhwayfun.springboot.rocketmq.starter.common.AbstractRocketMqConsumer;
-import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
-import org.apache.rocketmq.common.message.MessageExt;
-import org.springframework.stereotype.Component;
-
-import java.io.UnsupportedEncodingException;
-
-/**
- * @author rhwayfun
- * @since 0.0.1
- */
-/*@Component
-public class DemoRocketMqConsumer extends AbstractRocketMqConsumer {
-
-    @Override
-    public String getTopic() {
-        return "TopicTest";
-    }
-
-    @Override
-    public String getTags() {
-        return "TagA";
-    }
-
-    @Override
-    public ConsumeConcurrentlyStatus handle(MessageExt msg) {
-        try {
-            logger.info("start handle rocketmq msg, content:{}", new String(msg.getBody(), "UTF-8"));
-        } catch (UnsupportedEncodingException e) {
-            logger.error("handle rocketmq msg error.", e);
-        }
-        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
-    }
-}*/
diff --git a/spring-boot-rocketmq/src/main/resources/application.properties b/spring-boot-rocketmq/src/main/resources/application.properties
index b0a858e..70b6477 100644
--- a/spring-boot-rocketmq/src/main/resources/application.properties
+++ b/spring-boot-rocketmq/src/main/resources/application.properties
@@ -2,4 +2,4 @@ spring.application.name=spring-boot-rocketmq
 
 # Apache RocketMQ
 spring.rocketmq.nameServer=localhost:9876
-spring.rocketmq.consumerGroupName=spring-boot-rocketmq-consumer-group
\ No newline at end of file
+spring.rocketmq.producer-group-name=spring-boot-test-producer-group
\ No newline at end of file