YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-19 02:53:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix pending messages overflow strategy issue.

Browse Source
This commit is contained in:
Christian Kratky
2018-11-04 20:33:44 +01:00
parent 6fc9f12c34
commit 7181813f12
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs
+1 -1
View File
@@ -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)
{