#112 Check if connectOnCreate in connect/reconnect handling.

sclausen · Sep 5, 2018 · 2bab14f · 2bab14f
1 parent e81d6f2
commit 2bab14f
Showing 1 changed file with 10 additions and 6 deletions.
diff --git a/src/mqtt.service.ts b/src/mqtt.service.ts
@@ -316,17 +316,21 @@ export class MqttService {
   }
 
   private _handleOnConnect = (e: IOnConnectEvent) => {
-    Object.keys(this.observables).forEach((filter: string) => {
-      this.client.subscribe(filter);
-    });
+    if (this.options.connectOnCreate === true) {
+      Object.keys(this.observables).forEach((filter: string) => {
+        this.client.subscribe(filter);
+      });
+    }
     this.state.next(MqttConnectionState.CONNECTED);
     this._onConnect.emit(e);
   }
 
   private _handleOnReconnect = () => {
-    Object.keys(this.observables).forEach((filter: string) => {
-      this.client.subscribe(filter);
-    });
+    if (this.options.connectOnCreate === true) {
+      Object.keys(this.observables).forEach((filter: string) => {
+        this.client.subscribe(filter);
+      });
+    }
     this.state.next(MqttConnectionState.CONNECTING);
     this._onReconnect.emit();
   }