From f76e13028316e3d1757d871bb9f200945a72583d Mon Sep 17 00:00:00 2001 From: vbBerni Date: Wed, 19 Jun 2019 16:33:54 +0200 Subject: [PATCH] fix for failed publishing messages get removed from the message queue but not from the storage manager --- Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs | 1 + 1 file changed, 1 insertion(+) diff --git a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs index 59f1c9a9..b27bead1 100644 --- a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs +++ b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs @@ -408,6 +408,7 @@ namespace MQTTnet.Extensions.ManagedClient { _messageQueue.RemoveFirst(i => i.Id.Equals(message.Id)); } + _storageManager?.RemoveAsync(message).GetAwaiter().GetResult(); } } catch (Exception exception)