From b30fb8afd3cd6228bda9b182dc412bb3c8daf69c Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 17 十月 2024 16:28:48 +0800
Subject: [PATCH] CMQ转为Rabbitmq
---
src/main/java/com/yeshi/buwan/service/imp/VideoManager.java | 7 +++++--
1 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/imp/VideoManager.java b/src/main/java/com/yeshi/buwan/service/imp/VideoManager.java
index 9ed4ae3..c0b5f5d 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/VideoManager.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/VideoManager.java
@@ -7,7 +7,7 @@
import com.yeshi.buwan.service.inter.juhe.AlbumVideoMapService;
import com.yeshi.buwan.util.LogUtil;
import com.yeshi.buwan.util.StringUtil;
-import com.yeshi.buwan.util.mq.CMQManager;
+import com.yeshi.buwan.util.mq.rabbit.RabbitmqManager;
import org.hibernate.HibernateException;
import org.hibernate.Session;
import org.springframework.orm.hibernate4.HibernateCallback;
@@ -411,6 +411,9 @@
@Resource
private AlbumVideoMapService albumVideoMapService;
+ @Resource
+ private RabbitmqManager rabbitmqManager;
+
/**
* 鍒犻櫎瑙嗛
*
@@ -422,7 +425,7 @@
//娓呴櫎MongoDB鐩稿叧渚濊禆
albumVideoMapService.deleteByVideoId(videoId);
//鏇存柊鎼滅储寮曟搸鏁版嵁
- CMQManager.getInstance().addSolrMsg(videoId);
+ rabbitmqManager.addSolrMsg(videoId);
videoInfoDao.delete(new VideoInfo(videoId));
}
--
Gitblit v1.8.0