Cleanups

IoT/Connector/Data/Mqtt/Mqtt.cs

@@ -25,7 +25,16 @@ namespace BlubbFish.Utils.IoT.Connector.Data {
       } else {
         this.client.Connect(Guid.NewGuid().ToString());
       }
-      this.client.Subscribe(new String[] { "#" }, new Byte[] { MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE });
+      if (this.settings.ContainsKey("topic")) {
+        Int32 l = this.settings["topic"].Split(';').Length;
+        Byte[] qos = new Byte[l];
+        for (Int32 i = 0; i < qos.Length; i++) {
+          qos[i] = MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE;
+        }
+        this.client.Subscribe(this.settings["topic"].Split(';'), qos);
+      } else {
+        this.client.Subscribe(new String[] { "#" }, new Byte[] { MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE });
+      }
     }
 
     private void Client_MqttMsgPublishReceived(Object sender, MqttMsgPublishEventArgs e) {

Utils/OwnModel.cs

@@ -9,7 +9,7 @@ namespace BlubbFish.Utils
   public abstract class OwnModel<T> where T : class
   {
     private static readonly Lazy<T> _instance = new Lazy<T>(() => CreateInstanceOfT());
-    private List<OwnView> observer = new List<OwnView>();
+    private readonly List<OwnView> observer = new List<OwnView>();
     public static T Instance
     {
       get {
@@ -35,5 +35,6 @@ namespace BlubbFish.Utils
       this.observer.ForEach(delegate (OwnView view) { view.Update(); });
     }
     abstract protected void Init();
+    abstract public void Dispose();
   }
 }