修改mqtt解绑topic

puyang1017 · Mar 6, 2020 · 8b019d5 · 8b019d5
1 parent 52f0816
commit 8b019d5
Show file tree

Hide file tree

Showing 2 changed files with 38 additions and 2 deletions.
diff --git a/puymvpjava/src/main/java/com/android/puy/puymvpjava/mqttv3/IMqttStatusListener.java b/puymvpjava/src/main/java/com/android/puy/puymvpjava/mqttv3/IMqttStatusListener.java
@@ -37,6 +37,21 @@ public interface IMqttStatusListener {
      */
     void subscribeFail(IMqttToken iMqttToken, Throwable throwable);
 
+    /**
+     * 解绑订阅成功
+     *
+     * @param iMqttToken
+     */
+    void unSubscribeSuccess(IMqttToken iMqttToken);
+
+    /**
+     * 解绑订阅失败
+     *
+     * @param iMqttToken
+     * @param throwable
+     */
+    void unSubscribeFail(IMqttToken iMqttToken, Throwable throwable);
+
     /**
      * 链接完成
      *

diff --git a/puymvpjava/src/main/java/com/android/puy/puymvpjava/mqttv3/MqttV3.java b/puymvpjava/src/main/java/com/android/puy/puymvpjava/mqttv3/MqttV3.java
@@ -234,7 +234,7 @@ public void subscribe(List<String> topics, int subscribeQos) {
 
     public void unSubscribe(String topic) {
         try {
-            mqttClient.unsubscribe(topic, this.userContext, iMqttActionListener);
+            mqttClient.unsubscribe(topic, this.userContext, iMqttUnActionListener);
         } catch (MqttException e) {
             e.printStackTrace();
         }
@@ -247,7 +247,7 @@ public void unSubscribe(List<String> topics) {
         try {
             int size = topics.size();
             String[] subscribeTopics = topics.toArray(new String[size]);
-            mqttClient.unsubscribe(subscribeTopics, this.userContext, iMqttActionListener);
+            mqttClient.unsubscribe(subscribeTopics, this.userContext, iMqttUnActionListener);
         } catch (MqttException e) {
             e.printStackTrace();
         }
@@ -288,6 +288,27 @@ public void onFailure(IMqttToken iMqttToken, Throwable throwable) {
         }
     };
 
+    /**
+     * 订阅的动作后的回调
+     */
+    private IMqttActionListener iMqttUnActionListener = new IMqttActionListener() {
+        @Override
+        public void onSuccess(IMqttToken iMqttToken) {
+            //System.out.println("订阅成功");
+            if (mIMqttStatusListener != null) {
+                mIMqttStatusListener.unSubscribeSuccess(iMqttToken);
+            }
+        }
+
+        @Override
+        public void onFailure(IMqttToken iMqttToken, Throwable throwable) {
+            //System.out.println("订阅失败");
+            if (mIMqttStatusListener != null) {
+                mIMqttStatusListener.unSubscribeFail(iMqttToken, throwable);
+            }
+        }
+    };
+
     /**
      * 发布消息（默认topic）
      *