From d3ebf5b103d4deebd6ffb75f4471a6fddab8d764 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 05 九月 2020 17:30:30 +0800
Subject: [PATCH] '微信登录'
---
src/main/java/com/yeshi/buwan/util/mq/CMQManager.java | 34 +++++++++++++++++++++++++++++++++-
1 files changed, 33 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
index 8653ea4..9f9145b 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
@@ -2,6 +2,7 @@
import com.qcloud.cmq.Message;
import com.yeshi.buwan.dto.mq.IqiyiAlbum2MQMsg;
+import com.yeshi.buwan.dto.mq.SolrVideoMQMsg;
import java.util.ArrayList;
import java.util.List;
@@ -55,6 +56,37 @@
cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_IQIYI_2, handler);
}
- //鎼滅储寮曟搸
+
+ /**
+ * 鎼滅储寮曟搸
+ * @param id
+ */
+
+ /**
+ * 鎼滅储寮曟搸娑堟伅
+ *
+ * @param id
+ */
+ public void addSolrMsg(String id) {
+ cmqUtil.sendMsg(QUEUENAME_SOLR, id);
+ }
+
+ public List<SolrVideoMQMsg> consumeSolrMsg(int count) {
+ List<SolrVideoMQMsg> list = new ArrayList<>();
+ List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_SOLR);
+ if (msgList != null)
+ for (Message msg : msgList) {
+ SolrVideoMQMsg mm = new SolrVideoMQMsg();
+ mm.setHandler(msg.receiptHandle);
+ mm.setId(msg.msgBody);
+ list.add(mm);
+ }
+ return list;
+ }
+
+
+ public void deleteSolrMsg(String handler) {
+ cmqUtil.deleteMsg(QUEUENAME_SOLR, handler);
+ }
}
--
Gitblit v1.8.0