sdk/src/main/java/com/hdl/sdk/link/core/utils/mqtt/MqttRecvClient.java
@@ -181,6 +181,7 @@ connOpts.setConnectionTimeout(connectionTimeout); connOpts.setMqttVersion(MqttConnectOptions.MQTT_VERSION_3_1_1); connOpts.setMaxInflight(1000); sampleClient.setCallback(new MqttCallbackExtended() { public void connectComplete(boolean reconnect, String serverURI) { LogUtils.d(TAG, "连接成功");