From 054faae64c680cbe251b88909d2a92527b309113 Mon Sep 17 00:00:00 2001 From: lxu75 Date: Mon, 3 Mar 2025 14:13:37 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96=E5=88=86=E6=9E=90?= =?UTF-8?q?=E4=B8=AD=E5=BF=83=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ...mer.java => CommunityMessageConsumer.java} | 2 +- .../analytic/center/mq/MessageListener.java | 25 ------------------- 2 files changed, 1 insertion(+), 26 deletions(-) rename ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/{LtoMessageConsumer.java => CommunityMessageConsumer.java} (91%) delete mode 100644 ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/MessageListener.java diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/LtoMessageConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CommunityMessageConsumer.java similarity index 91% rename from ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/LtoMessageConsumer.java rename to ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CommunityMessageConsumer.java index 86d378a..e590206 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/LtoMessageConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CommunityMessageConsumer.java @@ -13,7 +13,7 @@ import org.springframework.stereotype.Component; @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.group}", topic = "${rocketmq.consumer.topic}", enableMsgTrace = true) -public class LtoMessageConsumer implements RocketMQListener{ +public class CommunityMessageConsumer implements RocketMQListener{ @Autowired private MqMessageRecordService mqMessageRecordService; diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/MessageListener.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/MessageListener.java deleted file mode 100644 index 8081b0c..0000000 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/MessageListener.java +++ /dev/null @@ -1,25 +0,0 @@ -//package com.volvo.ai.analytic.center.mq; -// -// -//import com.volvo.ai.analytic.center.constant.Constant; -//import com.volvo.ai.analytic.center.service.MqMessageRecordService; -//import lombok.extern.slf4j.Slf4j; -////import org.springframework.amqp.rabbit.annotation.RabbitListener; -//import org.springframework.beans.factory.annotation.Autowired; -//import org.springframework.stereotype.Component; -// -//@Slf4j -//@Component -//public class MessageListener { -// -// /* @Autowired -// private MqMessageRecordService mqMessageRecordService; -// -// //默认情况下，当使用@RabbitListener注解时，消息确认模式通常是自动的（AcknowledgeMode.AUTO）可以在yaml文件中更改， -// // 消息一旦被消费者接收并处理完成（即方法执行完成），就会自动发送ack确认给RabbitMQ。 -// @RabbitListener(queues = Constant.rabbitMqFormQueue) -// public void onMessage(String message) { -// log.info("Received message: " + message); -// boolean result = mqMessageRecordService.processMessageByMQ(message); -// }*/ -//}