JLChen
2020-10-28 c958e1806f0cc150644d9e8da82df0e6c8d8fe77
Android_HDL_SDK_XW/hdl_core/src/main/java/com/hdl/sdk/hdl_core/HDLDeviceManger/Core/HDLZigbeeMqtt.java
@@ -59,20 +59,24 @@
     */
    public static void sendMqttData1(String topic, String json) {
        HDLLog.info("send Mqtt to gateway:" + json);
        Log.d("111133", "sendMqttData1: " + json);
        Log.d("ZigbeeMqtt", "sendMqttData1: " + json);
        try {
            if(client == null){
                HDLZigbeeMqtt.connect1(HDLCommandText.getIpAddr());
            }
            MqttMessage message = new MqttMessage();
            message.setQos(2);
            message.setRetained(false);
            message.setPayload(json.getBytes());
            MqttDeliveryToken token = client.getTopic(topic).publish(message);
            token.waitForCompletion();
            Log.d("111133", "已经发送");
            Log.d("ZigbeeMqtt", "已经发送");
            HDLLog.info("message is published completely!");
        } catch (MqttException e) {
            Log.d("111133", "sendMqttData1: " + e.getMessage());
            Log.d("ZigbeeMqtt", "sendMqttData1 catch: " + e.getMessage());
            HDLLog.info("发送mqtt信息出错");
            e.printStackTrace();
//            e.printStackTrace();
        }
    }
}