Update tvbus

app/src/main/java/com/fongmi/android/tv/bean/Core.java

@@ -10,6 +10,8 @@ public class Core {
     private String name;
     @SerializedName("pass")
     private String pass;
+    @SerializedName("broker")
+    private String broker;
 
     public String getAuth() {
         return auth;
@@ -22,4 +24,8 @@ public class Core {
     public String getPass() {
         return pass;
     }
+
+    public String getBroker() {
+        return broker;
+    }
 }

app/src/main/java/com/fongmi/android/tv/player/source/TVBus.java

@@ -28,7 +28,7 @@ public class TVBus implements TVListener {
 
     public void init(Core core) {
         tvcore = TVCore.getInstance().listener(this);
-        TVService.start(App.get(), core.getAuth(), core.getName(), core.getPass());
+        TVService.start(App.get(), core.getAuth(), core.getName(), core.getPass(), core.getBroker());
     }
 
     public String fetch(String url) throws InterruptedException {

other/sample/live/offline.json

@@ -10,7 +10,8 @@
       "core": {
         "auth": "",
         "name": "",
-        "pass": ""
+        "pass": "",
+        "broker": ""
       }
     },
     {

other/sample/live/online.json

@@ -10,7 +10,8 @@
       "core": {
         "auth": "",
         "name": "",
-        "pass": ""
+        "pass": "",
+        "broker": ""
       }
     },
     {

tvbus/src/main/java/com/tvbus/engine/TVCore.java

@@ -49,6 +49,11 @@ public class TVCore {
         return this;
     }
 
+    public TVCore broker(String str) {
+        if (!TextUtils.isEmpty(str)) setMKBroker(nativeHandle, str);
+        return this;
+    }
+
     public TVCore name(String str) {
         if (!TextUtils.isEmpty(str)) setUsername(nativeHandle, str);
         return this;
@@ -105,6 +110,8 @@ public class TVCore {
 
     private native void setAuthUrl(long handle, String str);
 
+    private native void setMKBroker(long handle, String str);
+
     private native void setPassword(long handle, String str);
 
     private native void setUsername(long handle, String str);

tvbus/src/main/java/com/tvbus/engine/TVService.java

@@ -9,12 +9,13 @@ public class TVService extends Service {
 
     private TVCore tvcore;
 
-    public static void start(Context context, String auth, String name, String pass) {
+    public static void start(Context context, String auth, String name, String pass, String broker) {
         try {
             Intent intent = new Intent(context, TVService.class);
             intent.putExtra("auth", auth);
             intent.putExtra("name", name);
             intent.putExtra("pass", pass);
+            intent.putExtra("broker", broker);
             context.startService(intent);
         } catch (Exception e) {
             e.printStackTrace();
@@ -29,14 +30,9 @@ public class TVService extends Service {
         }
     }
 
-    @Override
-    public void onCreate() {
-        tvcore = TVCore.getInstance();
-    }
-
     @Override
     public int onStartCommand(Intent intent, int flags, int startId) {
-        tvcore.auth(intent.getStringExtra("auth")).name(intent.getStringExtra("name")).pass(intent.getStringExtra("pass"));
+        tvcore = TVCore.getInstance().auth(intent.getStringExtra("auth")).name(intent.getStringExtra("name")).pass(intent.getStringExtra("pass")).broker(intent.getStringExtra("broker"));
         tvcore.serv(0).play(8902).mode(1);
         tvcore.init(this);
         return START_NOT_STICKY;