Merge pull request #101 from bobmarco/patch-3

New override method for Connect()
eclipse-paho · Apr 16, 2019 · b2e64bc · b2e64bc
2 parents 0b73e23 + 4be37eb
commit b2e64bc
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>