CMQ转为Rabbitmq

admin

2024-10-17 b30fb8afd3cd6228bda9b182dc412bb3c8daf69c

 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));
    }