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/RabbitDelayConsumer.java | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/util/mq/rabbit/RabbitDelayConsumer.java b/src/main/java/com/yeshi/buwan/util/mq/rabbit/RabbitDelayConsumer.java
index 76b80c3..f05641e 100644
--- a/src/main/java/com/yeshi/buwan/util/mq/rabbit/RabbitDelayConsumer.java
+++ b/src/main/java/com/yeshi/buwan/util/mq/rabbit/RabbitDelayConsumer.java
@@ -7,6 +7,7 @@
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
import org.springframework.stereotype.Component;
import org.yeshi.utils.StringUtil;
@@ -19,24 +20,23 @@
* @description: 寤舵椂闃熷垪娑堣垂澶勭悊
* @date 2024/10/12 11:21
*/
-//@Component
-public class RabbitDelayConsumer {
+public class RabbitDelayConsumer implements ChannelAwareMessageListener {
- private Logger logger = LoggerFactory.getLogger("infoLog");
+ private Logger logger = LoggerFactory.getLogger("infoLog");
@Resource
private RabbitTemplate rabbitTemplate;
-// @RabbitListener(queues = RabbitmqSenderUtil.DELAY_QUEUE_NAME, ackMode = "MANUAL")
+ @Override
public void onMessage(Message message, Channel channel) throws Exception {
- String msg = new String( message.getBody(), StandardCharsets.UTF_8);
- logger.info("RabbitDelayConsumer-{}",msg);
- DelayMsgInfo msgInfo = new Gson().fromJson(msg, DelayMsgInfo.class);
- if(!StringUtil.isNullOrEmpty(msgInfo.getQueueName())){
- // 闃熷垪娑堟伅
+ String msg = new String(message.getBody(), StandardCharsets.UTF_8);
+ logger.info("RabbitDelayConsumer-{}", msg);
+ DelayMsgInfo msgInfo = new Gson().fromJson(msg, DelayMsgInfo.class);
+ if (!StringUtil.isNullOrEmpty(msgInfo.getQueueName())) {
+ // 闃熷垪娑堟伅
RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, msgInfo.getQueueName(), msgInfo.getMsg());
- }else{
+ } else {
// 浜ゆ崲鏈烘秷鎭�
RabbitmqSenderUtil.sendExchangeMsg(rabbitTemplate, msgInfo.getExchangeName(), msgInfo.getRoutingKey(), msgInfo.getMsg());
}
--
Gitblit v1.8.0