fix for failed publishing messages get removed from the message queue but not from the storage manager

2026-10-17 09:43:05 +08:00 · 2019-06-19 16:33:54 +02:00
parent 7a642802ed
commit f76e130283
1 changed files with 1 additions and 0 deletions
@@ -408,6 +408,7 @@ namespace MQTTnet.Extensions.ManagedClient
                    {
                        _messageQueue.RemoveFirst(i => i.Id.Equals(message.Id));
                    }
+                    _storageManager?.RemoveAsync(message).GetAwaiter().GetResult();
                }
            }
            catch (Exception exception)