From 07bafd5eb4203e86cd167db05c74ea09528f8faf Mon Sep 17 00:00:00 2001
From: chentaisen <14615430+chentaisen@user.noreply.gitee.com>
Date: Sun, 29 Sep 2024 20:32:57 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=88=E5=B9=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/muyu/parsing/mqtt/MqttTest.java        | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
index c8a514b..e2df8b6 100644
--- a/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
+++ b/cloud-modules/cloud-modules-parsing/src/main/java/com/muyu/parsing/mqtt/MqttTest.java
@@ -1,7 +1,6 @@
 package com.muyu.parsing.mqtt;
 
 import com.alibaba.fastjson2.JSONObject;
-import com.muyu.common.core.domain.Result;
 import com.muyu.common.kafka.constants.KafkaConstants;
 import com.muyu.parsing.domain.KafKaData;
 import com.muyu.parsing.domain.SysCarMessage;
@@ -15,9 +14,7 @@ import org.springframework.stereotype.Component;
 import javax.annotation.PostConstruct;
 import javax.annotation.Resource;
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.concurrent.CompletableFuture;
 
 
 /**
@@ -70,7 +67,7 @@ public class MqttTest {
                     log.info(new String(mqttMessage.getPayload()));
                     List<KafKaData> kafKaDataList = new ArrayList<>();
                     String[] test = string.split(" ");
-                    String[] results = new String[list.size()];
+//                    String[] results = new String[list.size()];
                     for (SysCarMessage carMessage : list) {
                         int start = Integer.parseInt(carMessage.getMessageStartIndex()) - 1;
                         int end = Integer.parseInt(carMessage.getMessageEndIndex());