buwan-server.git

概况
操作记录
提交次数
目录
文档
派生
对比

blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace

admin

2021-04-16 6e365a48a83e628759df3a5f25b3db97009c9f26

 src/main/java/com/yeshi/buwan/util/mq/CMQManager.java

@@ -242,7 +242,7 @@
     */

    public void addInternetSearchVideoUpdateMsg(InternetSearchVideoMQMsg msg) {
        cmqUtil.sendMsg(QUEUENAME_VIDEO_RESOURCE_DELETE, new Gson().toJson(msg));
        cmqUtil.sendMsg(QUEUENAME_UPDATE_INTERNET_SEARCH, new Gson().toJson(msg));
    }

    public List<InternetSearchVideoMQMsg> consumeInternetSearchVideoUpdateMsg(int count) {

			@@ -242,7 +242,7 @@
			*/

			public void addInternetSearchVideoUpdateMsg(InternetSearchVideoMQMsg msg) {
			cmqUtil.sendMsg(QUEUENAME_VIDEO_RESOURCE_DELETE, new Gson().toJson(msg));
			cmqUtil.sendMsg(QUEUENAME_UPDATE_INTERNET_SEARCH, new Gson().toJson(msg));
			}

			public List<InternetSearchVideoMQMsg> consumeInternetSearchVideoUpdateMsg(int count) {