rocketMQ常量定义

pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessResource.java

@@ -0,0 +1,12 @@
+package com.njcn.mq.constant;
+
+/**
+ * @author xy
+ */
+public interface BusinessResource {
+
+    /***
+     * App
+     */
+    String APP_RESOURCE = "APP";
+}

pqs-common/common-mq/src/main/java/com/njcn/mq/constant/BusinessTopic.java

@@ -15,10 +15,26 @@ public interface BusinessTopic {
     /**
      * 治理主送推送数据接收主题
      */
-    String NJCJ_APP_AUTO_DATA_TOPIC = "njcnAppAutoDataTopic";
+    String NJCN_APP_AUTO_DATA_TOPIC = "njcnAppAutoDataTopic";
 
     /**
      * 治理事件接收主题
      */
-    String NJCJ_APP_EVENT_TOPIC = "njcnAppEventTopic";
+    String NJCN_APP_EVENT_TOPIC = "njcnAppEventTopic";
+
+
+    interface AppDataTag {
+
+        /**
+         * 统计数据tag
+         */
+        String STAT_TAG = "stat";
+
+        /**
+         * 实时数据tag
+         */
+        String RT_TAG = "rt";
+    }
+
+
 }

pqs-common/common-mq/src/main/java/com/njcn/mq/template/AppAutoDataMessageTemplate.java

@@ -1,6 +1,7 @@
 package com.njcn.mq.template;
 
 import com.njcn.middle.rocket.template.RocketMQEnhanceTemplate;
+import com.njcn.mq.constant.BusinessResource;
 import com.njcn.mq.constant.BusinessTopic;
 import com.njcn.mq.message.AppAutoDataMessage;
 import org.apache.rocketmq.client.producer.SendResult;
@@ -22,7 +23,7 @@ public class AppAutoDataMessageTemplate extends RocketMQEnhanceTemplate {
     }
 
     public SendResult sendMember(AppAutoDataMessage appAutoDataMessage) {
-        appAutoDataMessage.setSource("APP-AUTO-DATA");
+        appAutoDataMessage.setSource(BusinessResource.APP_RESOURCE);
-        return send(BusinessTopic.NJCJ_APP_AUTO_DATA_TOPIC, "CREATE", appAutoDataMessage);
+        return send(BusinessTopic.NJCN_APP_AUTO_DATA_TOPIC, BusinessTopic.AppDataTag.STAT_TAG, appAutoDataMessage);
     }
 }