Fixed way of reconnecting lost connections

CleanSession default value must be true

Author: sebagomez

src/MQTTLib/MqttClient.cs

@@ -132,7 +132,8 @@ public static MqttStatus Connect(string url, MqttConfig config)
 						if (Connections.ContainsKey(key))
 						{
 							await Task.Delay(TimeSpan.FromSeconds(config.AutoReconnectDelay));
-							await client.ReconnectAsync();
+							MqttClientAuthenticateResult reconnectResult = await client.ConnectAsync(b.Build());
+							SubscribePreviousConnection(key, reconnectResult);
 						}
 					}
 					catch
@@ -232,9 +233,11 @@ public static MqttStatus Subscribe(Guid key, string topic, string gxproc, int qo
 				{
 					if (msg == null || msg.ApplicationMessage == null || msg.ApplicationMessage.Payload == null)
 						return;
-
+#if DEBUG
+					Console.WriteLine("");
 					Console.WriteLine($"Message arrived! Topic:{msg.ApplicationMessage.Topic} Payload:{Encoding.UTF8.GetString(msg.ApplicationMessage.Payload)}");
-
+					Console.WriteLine("");
+#endif
 					try
 					{
 						Assembly asm = Assembly.LoadFrom(fullPath);
@@ -248,8 +251,6 @@ public static MqttStatus Subscribe(Guid key, string topic, string gxproc, int qo
 							throw new NotImplementedException("Method 'execute' not found");
 
 						var obj = Activator.CreateInstance(procType);
-
-
 						methodInfo.Invoke(obj, new object[] { msg.ApplicationMessage.Topic, Encoding.UTF8.GetString(msg.ApplicationMessage.Payload) });
 					}
 					catch (Exception ex)

src/MQTTLib/MqttConfig.cs

@@ -20,7 +20,7 @@ public class MqttConfig
 		public string PrivateKey { get; set; }
 		public string ClientCerificatePassphrase { get; set; }
 		public int ProtocolVersion { get; set; } = 500;
-		public bool CleanSession { get; set; }
+		public bool CleanSession { get; set; } = true;
 		public bool AllowWildcardsInTopicFilters { get; set; }
 		public int AutoReconnectDelay { get; set; } = 5;
 		public int SessionExpiryInterval { get; set; } = 0;

tests/Publisher/Program.cs

@@ -21,13 +21,15 @@ static void Main(string[] args)
 				string command = Console.ReadLine();
 				while (command != "exit")
 				{
-					MqttStatus status=  MqttClient.Publish(key, topic, command, 2, true, 1);
+					MqttStatus status=  MqttClient.Publish(key, topic, command, 1, false, 60);
 					if (status.Error)
 						throw new Exception(status.ErrorMessage);
 
 					command = Console.ReadLine();
 				}
 
+				MqttClient.Disconnect(key);
+
 			}
 			catch (Exception ex)
 			{

tests/Subscriber/CommonConnection.cs

@@ -40,7 +40,7 @@ public static Guid Connect()
 			return Connect(config);
 		}
 
-		static Guid Connect(MqttConfig config)
+		public static Guid Connect(MqttConfig config)
 		{
 			string url = ConfigurationManager.AppSettings["url"];
 

tests/Subscriber/Program.cs

@@ -10,19 +10,31 @@ static void Main(string[] args)
 		{
 			try
 			{
+				MqttConfig config = Common.CommonConnection.GetConfig();
+
 				//Guid key = Common.CommonConnection.ConnectTLS();
-				Guid key = Common.CommonConnection.Connect();
+
+
+				config.CleanSession = false;
+				config.ClientId = "MyTest";
+
+				Guid key = Common.CommonConnection.Connect(config);
 
 				string topic = ConfigurationManager.AppSettings["topic"];
 
-				MqttStatus status = MqttClient.Subscribe(key, topic, "SaveMessage", 2);
+
+				Console.WriteLine($"Press <enter> to subscribe...");
+				Console.ReadLine();
+
+				MqttStatus status = MqttClient.Subscribe(key, topic, "SaveMessage", 1);
 
 				if (status.Error)
 					throw new Exception(status.ErrorMessage);
 
 				Console.WriteLine($"Subscribed to topic:{topic}");
 				Console.WriteLine($"Press <enter> to exit...");
 				Console.ReadLine();
+				MqttClient.Disconnect(key);
 			}
 			catch (Exception ex)
 			{