app/src/main/java/com/dayu/pipirrapp/activity/MainActivity.java
@@ -59,7 +59,6 @@ e.printStackTrace(); } mqttManager = new MqttManager(this, this); mqttManager.connect(); LiveEventBus.get(CommonKeyName.NetworkCallback).observeForever(new Observer<Object>() { @Override public void onChanged(Object o) { @@ -74,6 +73,7 @@ } } }); registNetCallBack(); } @@ -120,8 +120,9 @@ @Override protected void onDestroy() { super.onDestroy(); //关闭MQ try { //关闭MQ mqttManager.disconnect(); unregisterNetworkCallback(); } catch (Exception e) {