From 010ef2a907e66efd4702443c06cdd18f8a7ffa5b Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 30 十月 2024 14:08:53 +0800
Subject: [PATCH] IP归属地查询接口集成
---
src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/VideoUpdatePPTVListener.java | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/VideoUpdatePPTVListener.java b/src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/VideoUpdatePPTVListener.java
index 9830f9e..29cb4a1 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/VideoUpdatePPTVListener.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/VideoUpdatePPTVListener.java
@@ -11,7 +11,7 @@
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
-import org.springframework.stereotype.Component;
+import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
import javax.annotation.Resource;
import java.nio.charset.StandardCharsets;
@@ -22,8 +22,7 @@
* @description:
* @date 2024/9/26 13:47
*/
-@Component
-public class VideoUpdatePPTVListener {
+public class VideoUpdatePPTVListener implements ChannelAwareMessageListener {
private final static Logger logger = LoggerFactory.getLogger(VideoUpdatePPTVListener.class);
@Resource
@@ -31,7 +30,7 @@
@Resource
private PPTVService pptvService;
-
+ @Override
public void onMessage(Message message, Channel channel) throws Exception {
RabbitmqMsgConsumeUtil.processMessage(message, channel, rabbitTemplate, () -> {
String result = new String(message.getBody(), StandardCharsets.UTF_8);
--
Gitblit v1.8.0