diff --git a/src/main/java/com/rehome/mqttclienttemperature/AdminClientTemperatureApplication.java b/src/main/java/com/rehome/mqttclienttemperature/AdminClientTemperatureApplication.java index 03122ea..b95910e 100644 --- a/src/main/java/com/rehome/mqttclienttemperature/AdminClientTemperatureApplication.java +++ b/src/main/java/com/rehome/mqttclienttemperature/AdminClientTemperatureApplication.java @@ -58,14 +58,14 @@ public class AdminClientTemperatureApplication implements CommandLineRunner, App log.info(entry.getKey());//demo1Controller } try { - if (temperatureService != null) { - log.info("------------------------"); - log.info("TemperatureController is not empty"); - MqttRSAClient client = new MqttRSAClient(); - client.start(temperatureService); - }else { - log.info("temperatureService is empty"); - } +// if (temperatureService != null) { +// log.info("------------------------"); +// log.info("TemperatureController is not empty"); +// MqttRSAClient client = new MqttRSAClient(); +// client.start(temperatureService); +// }else { +// log.info("temperatureService is empty"); +// } if (temperatureEspService != null) { log.info("------------------------"); log.info("temperatureEspService is not empty"); diff --git a/src/main/java/com/rehome/mqttclienttemperature/MqttDianDengTechClient.java b/src/main/java/com/rehome/mqttclienttemperature/MqttDianDengTechClient.java index 035efcc..1513634 100644 --- a/src/main/java/com/rehome/mqttclienttemperature/MqttDianDengTechClient.java +++ b/src/main/java/com/rehome/mqttclienttemperature/MqttDianDengTechClient.java @@ -40,7 +40,7 @@ public class MqttDianDengTechClient { /** * 订阅标识 */ - public static String TOPIC_FILTER = "/device/esp8266/001"; + public static String TOPIC_FILTER = "/device/esp8266/+"; private volatile static MqttClient mqttClient; private static MqttConnectOptions options;