Browse Source

Refactoring and doc updates.

release/3.x.x
Christian Kratky 5 years ago
parent
commit
b175119008
3 changed files with 13 additions and 11 deletions
  1. +2
    -0
      Build/MQTTnet.nuspec
  2. +3
    -3
      Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs
  3. +8
    -8
      Source/MQTTnet/Client/MqttClient.cs

+ 2
- 0
Build/MQTTnet.nuspec View File

@@ -11,6 +11,8 @@
<requireLicenseAcceptance>false</requireLicenseAcceptance> <requireLicenseAcceptance>false</requireLicenseAcceptance>
<description>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.</description> <description>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.</description>
<releaseNotes> <releaseNotes>
* [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). * [Server] Added support for assigned client IDs (MQTTv5 only) (thanks to @bcrosnier).
</releaseNotes> </releaseNotes>
<copyright>Copyright Christian Kratky 2016-2019</copyright> <copyright>Copyright Christian Kratky 2016-2019</copyright>


+ 3
- 3
Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs View File

@@ -279,7 +279,7 @@ namespace MQTTnet.Extensions.ManagedClient
} }
catch (Exception exception) catch (Exception exception)
{ {
_logger.Error(exception, "Unhandled exception while maintaining connection.");
_logger.Error(exception, "Error exception while maintaining connection.");
} }
finally finally
{ {
@@ -328,11 +328,11 @@ namespace MQTTnet.Extensions.ManagedClient
} }
catch (MqttCommunicationException exception) catch (MqttCommunicationException exception)
{ {
_logger.Warning(exception, "Communication exception while maintaining connection.");
_logger.Warning(exception, "Communication error while maintaining connection.");
} }
catch (Exception exception) catch (Exception exception)
{ {
_logger.Error(exception, "Unhandled exception while maintaining connection.");
_logger.Error(exception, "Error exception while maintaining connection.");
} }
} }




+ 8
- 8
Source/MQTTnet/Client/MqttClient.cs View File

@@ -284,7 +284,7 @@ namespace MQTTnet.Client
} }
catch (Exception e) catch (Exception e)
{ {
_logger.Warning(e, "Error while waiting for tasks.");
_logger.Warning(e, "Error while waiting for internal tasks.");
} }
finally finally
{ {
@@ -412,11 +412,11 @@ namespace MQTTnet.Client
} }
else if (exception is MqttCommunicationException) 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 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()) if (!DisconnectIsPending())
@@ -470,11 +470,11 @@ namespace MQTTnet.Client
} }
else if (exception is MqttCommunicationException) else if (exception is MqttCommunicationException)
{ {
_logger.Warning(exception, "MQTT communication exception while receiving packets.");
_logger.Warning(exception, "Communication error while receiving packets.");
} }
else else
{ {
_logger.Error(exception, "Unhandled exception while receiving packets.");
_logger.Error(exception, "Error while receiving packets.");
} }


_packetDispatcher.Dispatch(exception); _packetDispatcher.Dispatch(exception);
@@ -542,11 +542,11 @@ namespace MQTTnet.Client
} }
else if (exception is MqttCommunicationException) else if (exception is MqttCommunicationException)
{ {
_logger.Warning(exception, "MQTT communication exception while receiving packets.");
_logger.Warning(exception, "Communication error while receiving packets.");
} }
else else
{ {
_logger.Error(exception, "Unhandled exception while receiving packets.");
_logger.Error(exception, "Error while receiving packets.");
} }


_packetDispatcher.Dispatch(exception); _packetDispatcher.Dispatch(exception);
@@ -597,7 +597,7 @@ namespace MQTTnet.Client
} }
catch (Exception exception) catch (Exception exception)
{ {
_logger.Error(exception, "Unhandled exception while handling application message.");
_logger.Error(exception, "Error while handling application message.");
} }
} }




Loading…
Cancel
Save