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/UpdateIntenetSearchListener.java | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/UpdateIntenetSearchListener.java b/src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/UpdateIntenetSearchListener.java
index 73ae93b..a0ec925 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/UpdateIntenetSearchListener.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/UpdateIntenetSearchListener.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 org.yeshi.utils.StringUtil;
import javax.annotation.Resource;
@@ -23,8 +23,7 @@
* @description:
* @date 2024/9/26 13:47
*/
-@Component
-public class UpdateIntenetSearchListener {
+public class UpdateIntenetSearchListener implements ChannelAwareMessageListener {
private final static Logger logger = LoggerFactory.getLogger(UpdateIntenetSearchListener.class);
@Resource
@@ -35,7 +34,7 @@
@Resource
private SolrInternetSearchVideoDataManager solrInternetSearchVideoDataManager;
-
+ @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