fix for #762

2026-10-18 10:26:11 +08:00 · 2019-09-30 16:05:23 +03:00
parent 2918be18c6
commit b12e3bc611
2 changed files with 6 additions and 6 deletions
@@ -349,7 +349,7 @@ namespace MQTTnet.Extensions.ManagedClient
                    // of the messages, the DropOldestQueuedMessage strategy would
                    // be unable to know which message is actually the oldest and would
                    // instead drop the first item in the queue.
-                    var message = _messageQueue.PeekAndWait();
+                    var message = _messageQueue.PeekAndWait(cancellationToken);
                    if (message == null)
                    {
                        continue;