diff --git a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Kafka.java b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/test/Kafka.java similarity index 98% rename from cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Kafka.java rename to cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/test/Kafka.java index d1a0ac1..fe39bf9 100644 --- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Kafka.java +++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/test/Kafka.java @@ -1,4 +1,4 @@ -package com.muyu.car; +package com.muyu.car.test; import com.alibaba.fastjson.JSONObject; import org.apache.kafka.clients.producer.KafkaProducer; diff --git a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Demo.java b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/test/MQTT.java similarity index 94% rename from cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Demo.java rename to cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/test/MQTT.java index 92a6092..ae3050e 100644 --- a/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/Demo.java +++ b/cloud-modules/cloud-modules-car/src/main/java/com/muyu/car/test/MQTT.java @@ -1,9 +1,8 @@ -package com.muyu.car; +package com.muyu.car.test; import org.eclipse.paho.client.mqttv3.*; -import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence; -public class Demo { +public class MQTT { public static void main(String[] args) {