some fix

Author: shiyinghan

README.md

@@ -21,7 +21,7 @@ allprojects {
 
 ```groovy
 dependencies {
-    implementation 'com.github.shiyinghan:MqttAndroid:1.0.0'
+    implementation 'com.github.shiyinghan:MqttAndroid:1.0.2'
 }
 ```
 

app/src/main/java/com/shiyinghan/mqtt/demo/base/AbstractActivity.java

@@ -1,4 +1,4 @@
-package com.shiyinghan.mqttdemo.base;
+package com.shiyinghan.mqtt.demo.base;
 
 import android.content.Context;
 import android.os.Bundle;
@@ -16,9 +16,9 @@
 import androidx.annotation.Nullable;
 import androidx.appcompat.app.AppCompatActivity;
 
-import com.shiyinghan.mqttdemo.R;
-import com.shiyinghan.mqttdemo.event.DummyEvent;
-import com.shiyinghan.mqttdemo.reactivex.RxUtils;
+import com.shiyinghan.mqtt.demo.R;
+import com.shiyinghan.mqtt.demo.event.DummyEvent;
+import com.shiyinghan.mqtt.demo.reactivex.RxUtils;
 
 import org.greenrobot.eventbus.EventBus;
 import org.greenrobot.eventbus.Subscribe;

example/.gitignore

@@ -0,0 +1 @@
+/build

example/src/main/java/com/shiyinghan/mqtt/example/MainActivity.java

@@ -206,13 +206,25 @@ public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                 }
             });
 
-            mqttClient.subscribe(subscriptionTopic1, qos, new IMqttMessageListener() {
-                @Override
-                public void messageArrived(String topic, MqttMessage message) throws Exception {
-                    // message Arrived!
-                    addToHistory("MessageArrived Topic: " + topic + " Payload: " + new String(message.getPayload()));
-                }
-            });
+//            mqttClient.subscribe(subscriptionTopic1, qos, this,
+//                    new IMqttActionListener() {
+//                        @Override
+//                        public void onSuccess(IMqttToken asyncActionToken) {
+//                            addToHistory("Subscribed!");
+//                        }
+//
+//                        @Override
+//                        public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
+//                            addToHistory("Failed to subscribe");
+//                        }
+//                    },
+//                    new IMqttMessageListener() {
+//                        @Override
+//                        public void messageArrived(String topic, MqttMessage message) throws Exception {
+//                            // message Arrived!
+//                            addToHistory("MessageArrived Topic: " + topic + " Payload: " + new String(message.getPayload()));
+//                        }
+//                    });
         } catch (MqttException e) {
             e.printStackTrace();
         }