|
@ -377,7 +377,7 @@ public class MqttManager { |
|
|
private class MqttActionCallback extends TXMqttActionCallBack { |
|
|
private class MqttActionCallback extends TXMqttActionCallBack { |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public void onConnectCompleted(Status status, boolean reconnect, Object userContext, String msg) { |
|
|
|
|
|
|
|
|
public void onConnectCompleted(Status status, boolean reconnect, Object userContext, String msg, Throwable cause) { |
|
|
if (status == Status.OK) { |
|
|
if (status == Status.OK) { |
|
|
LogManager.logInfo(TAG, "MQTT连接成功 - 重连: " + reconnect); |
|
|
LogManager.logInfo(TAG, "MQTT连接成功 - 重连: " + reconnect); |
|
|
isConnected = true; |
|
|
isConnected = true; |
|
@ -491,6 +491,11 @@ public class MqttManager { |
|
|
public boolean delOfflineLog() { |
|
|
public boolean delOfflineLog() { |
|
|
return false; // 不删除离线日志 |
|
|
return false; // 不删除离线日志 |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
|
public String readOfflineLog() { |
|
|
|
|
|
return null; // 不读取离线日志 |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|