src/main/java/com/ard/utils/mqtt/MqttConsumerCallback.java
@@ -81,14 +81,14 @@ if (null != topic && null != qos) { if (client.isConnected()) { client.subscribe(topic, qos); log.info("mqtt连接成功,客户端ID:" + PropertiesUtil.MQTT_CLIENT_ID); log.info("--订阅主题::" + Arrays.toString(topic)); log.debug("mqtt连接成功"); log.debug("--订阅主题::" + Arrays.toString(topic)); } else { log.info("mqtt连接失败,客户端ID:" + PropertiesUtil.MQTT_CLIENT_ID); log.debug("mqtt连接失败"); } } } catch (Exception e) { log.info("mqtt订阅主题异常:" + e); log.error("mqtt订阅主题异常:" + e); } } }