From 12a275918ee86c391bd3a9d9f91977dd139518a6 Mon Sep 17 00:00:00 2001
From: JanEggers <jan.eggers@ferag.com>
Date: Sat, 16 Sep 2017 08:02:48 +0200
Subject: [PATCH] fixed high load on server

---
 MQTTnet.Core/Server/MqttClientMessageQueue.cs | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/MQTTnet.Core/Server/MqttClientMessageQueue.cs b/MQTTnet.Core/Server/MqttClientMessageQueue.cs
index a8845e05..d5f20b0a 100644
--- a/MQTTnet.Core/Server/MqttClientMessageQueue.cs
+++ b/MQTTnet.Core/Server/MqttClientMessageQueue.cs
@@ -54,6 +54,12 @@ namespace MQTTnet.Core.Server
             var consumable = _pendingPublishPackets.GetConsumingEnumerable();
             while (!cancellationToken.IsCancellationRequested)
             {
+                if (_pendingPublishPackets.Count == 0)
+                {
+                    await Task.Delay(TimeSpan.FromMilliseconds(5));
+                    continue;
+                }
+
                 var packets = consumable.Take(_pendingPublishPackets.Count).ToList();
                 try
                 {