mq改造

themis-mq/src/main/java/com/qmth/themis/mq/enums/MqGroupEnum.java

@@ -1,9 +1,22 @@
 package com.qmth.themis.mq.enums;
 
+/**
+ * @Description: mq group enum
+ * @Param:
+ * @return:
+ * @Author: wangliang
+ * @Date: 2020/7/28
+ */
 public enum MqGroupEnum {
 
+    /**
+     * web group
+     */
     sessionConsumerWebGroup("themis-group-session-web"),
 
+    /**
+     * rWxappMonitor group
+     */
     sessionConsumerWxappMonitorGroup("themis-group-session-wxapp_monitor");
 
     private MqGroupEnum(String code){

themis-mq/src/main/java/com/qmth/themis/mq/enums/MqTagEnum.java

@@ -1,5 +1,12 @@
 package com.qmth.themis.mq.enums;
 
+/**
+ * @Description: mq tag enum
+ * @Param:
+ * @return:
+ * @Author: wangliang
+ * @Date: 2020/7/28
+ */
 public enum MqTagEnum {
 
     web;

themis-mq/src/main/java/com/qmth/themis/mq/enums/MqTopicEnum.java

@@ -1,7 +1,17 @@
 package com.qmth.themis.mq.enums;
 
+/**
+ * @Description: mq topic enum
+ * @Param:
+ * @return:
+ * @Author: wangliang
+ * @Date: 2020/7/28
+ */
 public enum MqTopicEnum {
 
+    /**
+     * session topic
+     */
     sessionTopic("themis-topic-session");
 
     private MqTopicEnum(String code){

themis-mq/src/main/java/com/qmth/themis/mq/templete/Concurrently.java

@@ -2,5 +2,12 @@ package com.qmth.themis.mq.templete;
 
 import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
 
+/**
+ * @Description: mq concurrent 并行消费
+ * @Param:
+ * @return:
+ * @Author: wangliang
+ * @Date: 2020/7/28
+ */
 public interface Concurrently extends MessageListenerConcurrently {
 }

themis-mq/src/main/java/com/qmth/themis/mq/templete/Orderly.java

@@ -1,4 +1,13 @@
 package com.qmth.themis.mq.templete;
 
-public interface Orderly {
+import org.apache.rocketmq.client.consumer.listener.MessageListenerOrderly;
+
+/**
+ * @Description: mq concurrent 顺序消费
+ * @Param:
+ * @return:
+ * @Author: wangliang
+ * @Date: 2020/7/28
+ */
+public interface Orderly extends MessageListenerOrderly {
 }

themis-mq/src/main/java/com/qmth/themis/mq/templete/impl/SessionConcurrentlyImpl.java

@@ -6,9 +6,15 @@ import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
 import org.apache.rocketmq.common.message.MessageExt;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-
 import java.util.List;
 
+/**
+ * @Description: mq 会话并行消费监听
+ * @Param:
+ * @return:
+ * @Author: wangliang
+ * @Date: 2020/7/28
+ */
 public class SessionConcurrentlyImpl implements Concurrently {
     private final static Logger log = LoggerFactory.getLogger(SessionConcurrentlyImpl.class);