From 7181813f12d510a64fc76fb9b429858001513ac7 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Sun, 4 Nov 2018 20:33:44 +0100 Subject: [PATCH] Fix pending messages overflow strategy issue. --- Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs index 16d8e9b5..6dec29fe 100644 --- a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs +++ b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs @@ -116,7 +116,7 @@ namespace MQTTnet.Extensions.ManagedClient ManagedMqttApplicationMessage skippedMessage = null; lock (_messageQueue) { - if (_messageQueue.Count > _options.MaxPendingMessages) + if (_messageQueue.Count >= _options.MaxPendingMessages) { if (_options.PendingMessagesOverflowStrategy == MqttPendingMessagesOverflowStrategy.DropNewMessage) {