diff --git a/Build/MQTTnet.nuspec b/Build/MQTTnet.nuspec index cc9aeaa..25d1acf 100644 --- a/Build/MQTTnet.nuspec +++ b/Build/MQTTnet.nuspec @@ -11,6 +11,8 @@ false MQTTnet is a high performance .NET library for MQTT based communication. It provides a MQTT client and a MQTT server (broker) and supports v3.1.0, v3.1.1 and v5.0.0 of the MQTT protocol. +* [Client] Improve connection stability (thanks to @jltjohanlindqvist). +* [ManagedClient] Fixed a memory leak (thanks to @zawodskoj). * [Server] Added support for assigned client IDs (MQTTv5 only) (thanks to @bcrosnier). Copyright Christian Kratky 2016-2019 diff --git a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs index 50310be..add5f76 100644 --- a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs +++ b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs @@ -279,7 +279,7 @@ namespace MQTTnet.Extensions.ManagedClient } catch (Exception exception) { - _logger.Error(exception, "Unhandled exception while maintaining connection."); + _logger.Error(exception, "Error exception while maintaining connection."); } finally { @@ -328,11 +328,11 @@ namespace MQTTnet.Extensions.ManagedClient } catch (MqttCommunicationException exception) { - _logger.Warning(exception, "Communication exception while maintaining connection."); + _logger.Warning(exception, "Communication error while maintaining connection."); } catch (Exception exception) { - _logger.Error(exception, "Unhandled exception while maintaining connection."); + _logger.Error(exception, "Error exception while maintaining connection."); } } diff --git a/Source/MQTTnet/Client/MqttClient.cs b/Source/MQTTnet/Client/MqttClient.cs index 527a5cd..c8aa859 100644 --- a/Source/MQTTnet/Client/MqttClient.cs +++ b/Source/MQTTnet/Client/MqttClient.cs @@ -284,7 +284,7 @@ namespace MQTTnet.Client } catch (Exception e) { - _logger.Warning(e, "Error while waiting for tasks."); + _logger.Warning(e, "Error while waiting for internal tasks."); } finally { @@ -412,11 +412,11 @@ namespace MQTTnet.Client } else if (exception is MqttCommunicationException) { - _logger.Warning(exception, "MQTT communication exception while sending/receiving keep alive packets."); + _logger.Warning(exception, "Communication error while sending/receiving keep alive packets."); } else { - _logger.Error(exception, "Unhandled exception while sending/receiving keep alive packets."); + _logger.Error(exception, "Error exception while sending/receiving keep alive packets."); } if (!DisconnectIsPending()) @@ -470,11 +470,11 @@ namespace MQTTnet.Client } else if (exception is MqttCommunicationException) { - _logger.Warning(exception, "MQTT communication exception while receiving packets."); + _logger.Warning(exception, "Communication error while receiving packets."); } else { - _logger.Error(exception, "Unhandled exception while receiving packets."); + _logger.Error(exception, "Error while receiving packets."); } _packetDispatcher.Dispatch(exception); @@ -542,11 +542,11 @@ namespace MQTTnet.Client } else if (exception is MqttCommunicationException) { - _logger.Warning(exception, "MQTT communication exception while receiving packets."); + _logger.Warning(exception, "Communication error while receiving packets."); } else { - _logger.Error(exception, "Unhandled exception while receiving packets."); + _logger.Error(exception, "Error while receiving packets."); } _packetDispatcher.Dispatch(exception); @@ -597,7 +597,7 @@ namespace MQTTnet.Client } catch (Exception exception) { - _logger.Error(exception, "Unhandled exception while handling application message."); + _logger.Error(exception, "Error while handling application message."); } }