Cancel send operations at diconnection to avoid endless blocking (#43)

siemens · Sep 21, 2022 · 6850bbd · 6850bbd
1 parent 10a7d06
commit 6850bbd
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Client/Client.cs b/src/Client/Client.cs
@@ -180,7 +180,7 @@ async Task TrySendKeepAliveMessagesAsync( CancellationToken cancellationToken )
                     Logger.Error( "Error exception while sending/receiving keep alive packets. " + exception );
                 }
 
-                await m_MqttClient?.DisconnectAsync();
+                await m_MqttClient?.DisconnectAsync(MqttClientDisconnectReason.KeepAliveTimeout);
             }
             finally
             {
@@ -892,7 +892,7 @@ private void Publish( byte[] payload, string topicPrefix, ushort dataSetWriterId
             {
                 try
                 {
-                    m_MqttClient.PublishAsync(messageBuilder.Build())
+                    m_MqttClient.PublishAsync(messageBuilder.Build(), m_BackgroundCancellationToken.Token)
                                 .Wait();
 
                     m_LastPacketSentTimestamp = DateTime.UtcNow;