|
|
@ -245,8 +245,10 @@ public class MQTTService extends Service { |
|
|
disconnectMqtt(); |
|
|
disconnectMqtt(); |
|
|
stopSelf(); |
|
|
stopSelf(); |
|
|
try { |
|
|
try { |
|
|
client.disconnect(); |
|
|
|
|
|
} catch (MqttException e) { |
|
|
|
|
|
|
|
|
if (client != null) { |
|
|
|
|
|
client.disconnect(); |
|
|
|
|
|
} |
|
|
|
|
|
} catch (Exception e) { |
|
|
e.printStackTrace(); |
|
|
e.printStackTrace(); |
|
|
} |
|
|
} |
|
|
EventBus.getDefault().unregister(this); |
|
|
EventBus.getDefault().unregister(this); |
|
|
@ -464,7 +466,7 @@ public class MQTTService extends Service { |
|
|
IMqttToken disconnectToken = client.disconnect(); |
|
|
IMqttToken disconnectToken = client.disconnect(); |
|
|
// disconnectToken.waitForCompletion();
|
|
|
// disconnectToken.waitForCompletion();
|
|
|
} |
|
|
} |
|
|
} catch (MqttException e) { |
|
|
|
|
|
|
|
|
} catch (Exception e) { |
|
|
LoggerUtil.e(TAG, "断开MQTT连接失败", e); |
|
|
LoggerUtil.e(TAG, "断开MQTT连接失败", e); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|