New override method for Connect()

Signed-off-by: Marco Sacco <[email protected]>
eclipse-paho · Apr 2, 2019 · 4be37eb · 4be37eb
1 parent 0b73e23
commit 4be37eb
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/M2Mqtt/MqttClient.cs b/M2Mqtt/MqttClient.cs
@@ -481,6 +481,18 @@ public byte Connect(string clientId)
             return this.Connect(clientId, null, null, false, MqttMsgConnect.QOS_LEVEL_AT_MOST_ONCE, false, null, null, true, MqttMsgConnect.KEEP_ALIVE_PERIOD_DEFAULT);
         }
 
+	/// <summary>
+        /// Connect to broker
+        /// </summary>
+        /// <param name="clientId">Client identifier</param>
+        /// <param name="cleanSession">Clean sessione flag</param>
+        /// <returns>Return code of CONNACK message from broker</returns>
+        public byte Connect(string clientId,
+            bool cleanSession)
+        {
+            return this.Connect(clientId, null, null, false, MqttMsgConnect.QOS_LEVEL_AT_MOST_ONCE, false, null, null, cleanSession, MqttMsgConnect.KEEP_ALIVE_PERIOD_DEFAULT);
+        }
+
         /// <summary>
         /// Connect to broker
         /// </summary>