From 5405154d6979f1b50ce2d881bb164b1acca80b6d Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 15 一月 2021 18:58:18 +0800
Subject: [PATCH] 修改相关bug
---
service-lucky/src/main/java/com/ks/lucky/util/mq/CMQManager.java | 27 +++++++++++++++++----------
1 files changed, 17 insertions(+), 10 deletions(-)
diff --git a/service-lucky/src/main/java/com/ks/lucky/util/mq/CMQManager.java b/service-lucky/src/main/java/com/ks/lucky/util/mq/CMQManager.java
index 661d972..2690eed 100644
--- a/service-lucky/src/main/java/com/ks/lucky/util/mq/CMQManager.java
+++ b/service-lucky/src/main/java/com/ks/lucky/util/mq/CMQManager.java
@@ -9,6 +9,8 @@
import com.ks.lucky.pojo.DTO.mq.ActivityStateChangeMsgDTO;
import com.ks.lucky.utils.LuckyCMQConstant;
import com.qcloud.cmq.Message;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.yeshi.utils.CMQUtil;
import org.yeshi.utils.JsonUtil;
@@ -19,6 +21,7 @@
public class CMQManager {
+ private final static Logger logger = LoggerFactory.getLogger(CMQManager.class);
private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
@@ -151,8 +154,8 @@
*/
public void publishActivityStateChangeMsg(ActivityStateChangeMsgDTO dto) {
List<String> tagList = new ArrayList<>();
- tagList.add(LuckyCMQConstant.TAG_ACTIVITY_STATE_CHANGE);
- cmqUtil.publishTopicMessage(LuckyCMQConstant.TOPIC_ACTIVITY_STATE_CHANGE, tagList, JsonUtil.getSimpleGson().toJson(dto));
+// tagList.add(LuckyCMQConstant.TAG_ACTIVITY_STATE_CHANGE);
+ cmqUtil.publishTopicMessage(LuckyCMQConstant.TOPIC_ACTIVITY_STATE_CHANGE, JsonUtil.getSimpleGson().toJson(dto));
}
@@ -163,8 +166,9 @@
*/
public void publishActivityAssistMsg(ActivityAssistMsgDTO dto) {
List<String> tagList = new ArrayList<>();
- tagList.add(LuckyCMQConstant.TAG_ASSIST);
- cmqUtil.publishTopicMessage(LuckyCMQConstant.TOPIC_ASSIST, tagList, JsonUtil.getSimpleGson().toJson(dto));
+// tagList.add(LuckyCMQConstant.TAG_ASSIST);
+ String msgId = cmqUtil.publishTopicMessage(LuckyCMQConstant.TOPIC_ASSIST, JsonUtil.getSimpleGson().toJson(dto));
+ logger.info("publishActivityJoinMsg:" + msgId);
}
/**
@@ -173,20 +177,23 @@
* @param dto
*/
public void publishActivityDrawnMsg(ActivityDrawnMsgDTO dto) {
- List<String> tagList = new ArrayList<>();
- tagList.add(LuckyCMQConstant.TAG_ACTIVITY_DRAWN);
- cmqUtil.publishTopicMessage(LuckyCMQConstant.TOPIC_ACTIVITY_DRAWN, tagList, JsonUtil.getSimpleGson().toJson(dto));
+// List<String> tagList = new ArrayList<>();
+// tagList.add(LuckyCMQConstant.TAG_ACTIVITY_DRAWN);
+ String msgId = cmqUtil.publishTopicMessage(LuckyCMQConstant.TOPIC_ACTIVITY_DRAWN, JsonUtil.getSimpleGson().toJson(dto));
+ logger.info("publishActivityDrawnMsg:" + msgId);
}
/**
* 娲诲姩鍙備笌淇℃伅
+ *
* @param dto
*/
public void publishActivityJoinMsg(ActivityJoinMsgDTO dto) {
- List<String> tagList = new ArrayList<>();
- tagList.add(LuckyCMQConstant.TAG_ACTIVITY_JOIN);
- cmqUtil.publishTopicMessage(LuckyCMQConstant.TOPIC_ACTIVITY_JOIN, tagList, JsonUtil.getSimpleGson().toJson(dto));
+// List<String> tagList = new ArrayList<>();
+// tagList.add(LuckyCMQConstant.TAG_ACTIVITY_JOIN);
+ String msgId = cmqUtil.publishTopicMessage(LuckyCMQConstant.TOPIC_ACTIVITY_JOIN, JsonUtil.getSimpleGson().toJson(dto));
+ logger.info("publishActivityJoinMsg:" + msgId);
}
}
--
Gitblit v1.8.0