From 89e370bfdda29ac8a8f7080a18dc09a6ddc75c09 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 26 十月 2020 18:42:16 +0800
Subject: [PATCH] 风行爱奇艺视频更新
---
src/main/java/com/yeshi/buwan/util/SpringContext.java | 9 +++------
1 files changed, 3 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/util/SpringContext.java b/src/main/java/com/yeshi/buwan/util/SpringContext.java
index 5858532..54be0b3 100644
--- a/src/main/java/com/yeshi/buwan/util/SpringContext.java
+++ b/src/main/java/com/yeshi/buwan/util/SpringContext.java
@@ -2,12 +2,11 @@
import com.yeshi.buwan.domain.ResourceVideo;
import com.yeshi.buwan.domain.VideoInfo;
-import com.yeshi.buwan.dto.mq.CMQConsumeMsg;
+import com.yeshi.buwan.dto.mq.CMQResult;
import com.yeshi.buwan.dto.mq.FunTVAlbum2MQMsg;
import com.yeshi.buwan.dto.mq.IqiyiAlbum2MQMsg;
import com.yeshi.buwan.dto.mq.SolrVideoMQMsg;
import com.yeshi.buwan.funtv.entity.FunTVAlbum2;
-import com.yeshi.buwan.funtv.entity.FunTVVideo2;
import com.yeshi.buwan.iqiyi.entity.IqiyiAlbum2;
import com.yeshi.buwan.service.imp.JobThreadExecutorServiceImpl;
import com.yeshi.buwan.service.imp.ResourceVideoService;
@@ -33,7 +32,6 @@
@Component
public class SpringContext implements ApplicationListener<ContextRefreshedEvent> {
-
@Resource
private VideoInfoService videoInfoService;
@@ -48,7 +46,6 @@
@Resource
private ResourceVideoService resourceVideoService;
-
private static boolean isInited = false;
@@ -157,9 +154,9 @@
@Override
public void run() {
while (true) {
- List<CMQConsumeMsg> cmqMsgList = CMQManager.getInstance().consumeVideoResourceDeleteMsg(16);
+ List<CMQResult> cmqMsgList = CMQManager.getInstance().consumeVideoResourceDeleteMsg(16);
if (cmqMsgList != null)
- for (CMQConsumeMsg msg : cmqMsgList) {
+ for (CMQResult msg : cmqMsgList) {
try {
String videoId = msg.getData() + "";
//鏌ヨ璧勬簮鍒楄〃
--
Gitblit v1.8.0