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)
                     {