mqtt: fix invalid url busting settings

plugins/mqtt/package-lock.json

@@ -1,12 +1,12 @@
 {
    "name": "@scrypted/mqtt",
-   "version": "0.0.54",
+   "version": "0.0.55",
    "lockfileVersion": 2,
    "requires": true,
    "packages": {
       "": {
          "name": "@scrypted/mqtt",
-         "version": "0.0.54",
+         "version": "0.0.55",
          "dependencies": {
             "@types/node": "^16.6.1",
             "aedes": "^0.46.1",
@@ -39,7 +39,7 @@
       },
       "../../sdk": {
          "name": "@scrypted/sdk",
-         "version": "0.0.202",
+         "version": "0.0.206",
          "dev": true,
          "license": "ISC",
          "dependencies": {

plugins/mqtt/package.json

@@ -41,5 +41,5 @@
       "@scrypted/common": "file:../../common",
       "@types/nunjucks": "^3.2.0"
    },
-   "version": "0.0.54"
+   "version": "0.0.55"
 }

plugins/mqtt/src/main.ts

@@ -171,7 +171,12 @@ class MqttPublisherMixin extends SettingsMixinDeviceBase<any> {
         super(options);
 
         this.device = systemManager.getDeviceById(this.id);
-        this.connectClient();
+        try {
+            this.connectClient();
+        }
+        catch (e) {
+            this.console.error('error while connecting client.', e);
+        }
 
         this.listener = this.device.listen(undefined, (eventSource, eventDetails, eventData) => {
             const { property } = eventDetails;
@@ -224,7 +229,6 @@ class MqttPublisherMixin extends SettingsMixinDeviceBase<any> {
         else {
             this.storage.setItem(key, value.toString());
         }
-        this.client.end();
         this.connectClient();
     }