From 81db7b3b070c003e6f5f0d1c757ab30b6f42c944 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 10 十月 2020 18:49:41 +0800
Subject: [PATCH] 百度内容联盟
---
src/main/java/com/yeshi/buwan/util/mq/CMQManager.java | 35 ++++++++++++++++++++++++++++++++---
1 files changed, 32 insertions(+), 3 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 9f9145b..7a52f57 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/CMQManager.java
@@ -1,6 +1,7 @@
package com.yeshi.buwan.util.mq;
import com.qcloud.cmq.Message;
+import com.yeshi.buwan.dto.mq.FunTVAlbum2MQMsg;
import com.yeshi.buwan.dto.mq.IqiyiAlbum2MQMsg;
import com.yeshi.buwan.dto.mq.SolrVideoMQMsg;
@@ -16,6 +17,8 @@
public static String QUEUENAME_SOLR = "buwan-solr";
//瑙嗛鏇存柊-鐖卞鑹�2
public static String QUEUENAME_VIDEO_UPDATE_IQIYI_2 = "buwan-video-update-iqiyi2";
+ //瑙嗛鏇存柊-椋庤2
+ public static String QUEUENAME_VIDEO_UPDATE_FUNTV_2 = "buwan-video-update-funtv2";
static {
@@ -23,6 +26,7 @@
// 鏈�澶ф秷鎭负1M
cmqUtil.createQueue(QUEUENAME_SOLR, 1024 * 1024);
cmqUtil.createQueue(QUEUENAME_VIDEO_UPDATE_IQIYI_2, 1024 * 1024);
+ cmqUtil.createQueue(QUEUENAME_VIDEO_UPDATE_FUNTV_2, 1024 * 1024);
}
public static CMQManager getInstance() {
@@ -33,12 +37,12 @@
//娣诲姞涓撹緫鏇存柊娑堟伅
- public void addAlbumUpdateMsg(Long id) {
+ public void addIqiyiAlbumUpdateMsg(Long id) {
cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_IQIYI_2, id + "");
}
//娑堣垂涓撹緫鏇存柊娑堟伅
- public List<IqiyiAlbum2MQMsg> consumeAlbumUpdateMsg(int count) {
+ public List<IqiyiAlbum2MQMsg> consumeIqiyiAlbumUpdateMsg(int count) {
List<IqiyiAlbum2MQMsg> list = new ArrayList<>();
List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_UPDATE_IQIYI_2);
if (msgList != null)
@@ -52,11 +56,36 @@
}
//鍒犻櫎涓撹緫鏇存柊娑堟伅
- public void deleteAlbumUpdateMsg(String handler) {
+ public void deleteIqiyiAlbumUpdateMsg(String handler) {
cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_IQIYI_2, handler);
}
+ //娣诲姞涓撹緫鏇存柊娑堟伅
+ public void addFunTVAlbumUpdateMsg(String id) {
+ cmqUtil.sendMsg(QUEUENAME_VIDEO_UPDATE_FUNTV_2, id );
+ }
+
+ //娑堣垂涓撹緫鏇存柊娑堟伅
+ public List<FunTVAlbum2MQMsg> consumeFunTVAlbumUpdateMsg(int count) {
+ List<FunTVAlbum2MQMsg> list = new ArrayList<>();
+ List<Message> msgList = cmqUtil.recieveMsg(count, QUEUENAME_VIDEO_UPDATE_FUNTV_2);
+ if (msgList != null)
+ for (Message msg : msgList) {
+ FunTVAlbum2MQMsg mm = new FunTVAlbum2MQMsg();
+ mm.setHandler(msg.receiptHandle);
+ mm.setId(msg.msgBody);
+ list.add(mm);
+ }
+ return list;
+ }
+
+ //鍒犻櫎涓撹緫鏇存柊娑堟伅
+ public void deleteFunTVAlbumUpdateMsg(String handler) {
+ cmqUtil.deleteMsg(QUEUENAME_VIDEO_UPDATE_FUNTV_2, handler);
+ }
+
+
/**
* 鎼滅储寮曟搸
* @param id
--
Gitblit v1.8.0