初始化分析中心代码

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;

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/MessageListener.java

@@ -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);
-//    }*/
-//}