Commit e375bf95 authored by litengwei's avatar litengwei

bug修复

parent 69729a35
...@@ -425,7 +425,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -425,7 +425,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
jsonObjectXf.put("data", jsonObjects); jsonObjectXf.put("data", jsonObjects);
try { try {
emqKeeper.getMqttClient().publish("eqm.xf.created",jsonObjectXf.toString().getBytes(),1,false); emqKeeper.getMqttClient().publish("emq.xf.created",jsonObjectXf.toString().getBytes(),1,false);
} catch (MqttException e) { } catch (MqttException e) {
e.printStackTrace(); e.printStackTrace();
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment