diff --git a/app/src/main/java/com/ouxuan/oxface/device/MqttManager.java b/app/src/main/java/com/ouxuan/oxface/device/MqttManager.java
index 264f887..e9959ee 100644
--- a/app/src/main/java/com/ouxuan/oxface/device/MqttManager.java
+++ b/app/src/main/java/com/ouxuan/oxface/device/MqttManager.java
@@ -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);
         }