‘liusuyi’
2023-08-10 ad89fdba09b8f0596ed41c5b31de6f34fe1ce620
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连接成功,客户端ID:" + PropertiesUtil.MQTT_CLIENT_ID);
                    log.debug("--订阅主题::" + Arrays.toString(topic));
                } else {
                    log.info("mqtt连接失败,客户端ID:" + PropertiesUtil.MQTT_CLIENT_ID);
                    log.debug("mqtt连接失败,客户端ID:" + PropertiesUtil.MQTT_CLIENT_ID);
                }
            }
        } catch (Exception e) {
            log.info("mqtt订阅主题异常:" + e);
            log.error("mqtt订阅主题异常:" + e);
        }
    }
}