diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelsKafkaMessage.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelsKafkaMessage.java
index defe82b..c9bb4b5 100644
--- a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelsKafkaMessage.java
+++ b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelsKafkaMessage.java
@@ -9,7 +9,6 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -43,8 +42,8 @@ public class ModelsKafkaMessage {
             add("stored-event");
         }
     };
-    @Autowired
-    private RabbitTemplate rabbitTemplate;
+//    @Autowired
+//    private RabbitTemplate rabbitTemplate;
 
     /**
      * 消费者配置
@@ -75,15 +74,15 @@ public class ModelsKafkaMessage {
                     List<CoupletMsgData> coupletMsgDataList = sendMsg(str);
                     for (CoupletMsgData msgData : coupletMsgDataList) {
                         log.info("解析到车辆数据：{}", msgData);
-//                        for (String string : strings) {
-//                            IncidentService incidentService = SpringUtils.getBean(string);
-//                            incidentService.incident(msgData);
-//                        }
+                        for (String string : strings) {
+                            IncidentService incidentService = SpringUtils.getBean(string);
+                            incidentService.incident(msgData);
+                        }
                         //发送消息
-                        rabbitTemplate.convertAndSend("couplet-code-queue",msgData,message -> {
-                            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
-                            return message;
-                        });
+//                        rabbitTemplate.convertAndSend("couplet-code-queue",msgData,message -> {
+//                            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
+//                            return message;
+//                        });
 
                         try {
                             sleep(100);