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<MessageExt>{
+public class CommunityMessageConsumer implements RocketMQListener<MessageExt>{
 
     @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);
-//    }*/
-//}