|
|
@ -412,7 +412,7 @@ public class MqttManager { |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void onPublishCompleted(Status status, IMqttToken token, Object userContext, String errMsg) { |
|
|
|
public void onPublishCompleted(Status status, IMqttToken token, Object userContext, String errMsg, Throwable cause) { |
|
|
|
if (status == Status.OK) { |
|
|
|
LogManager.logDebug(TAG, "消息发布成功"); |
|
|
|
} else { |
|
|
@ -421,7 +421,7 @@ public class MqttManager { |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void onSubscribeCompleted(Status status, IMqttToken token, Object userContext, String errMsg) { |
|
|
|
public void onSubscribeCompleted(Status status, IMqttToken asyncActionToken, Object userContext, String errMsg, Throwable cause) { |
|
|
|
if (status == Status.OK) { |
|
|
|
LogManager.logInfo(TAG, "主题订阅成功: " + subscribeTopic); |
|
|
|
} else { |
|
|
@ -430,7 +430,7 @@ public class MqttManager { |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void onUnSubscribeCompleted(Status status, IMqttToken token, Object userContext, String errMsg) { |
|
|
|
public void onUnSubscribeCompleted(Status status, IMqttToken asyncActionToken, Object userContext, String errMsg, Throwable cause) { |
|
|
|
LogManager.logInfo(TAG, "取消订阅完成: " + errMsg); |
|
|
|
} |
|
|
|
|
|
|
|