| | |
| | | */ |
| | | 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(); |
| | | } |
| | | } |
| | | } |