From 103517088667fd9775cb13caace69d541b66ffdf Mon Sep 17 00:00:00 2001
From: Haiping Chen <haiping008@gmail.com>
Date: Sat, 21 Dec 2024 15:41:15 +0000
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DFastMoss=E7=99=BB=E5=BD=95?=
 =?UTF-8?q?=E6=94=B9=E7=89=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../BotSharp.Core/Infrastructures/Events/RedisSubscriber.cs     | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisSubscriber.cs b/src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisSubscriber.cs
index fb035aeb..d53c9400 100644
--- a/src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisSubscriber.cs
+++ b/src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisSubscriber.cs
@@ -105,6 +105,8 @@ public class RedisSubscriber : IEventSubscriber
             catch (Exception ex)
             {
                 _logger.LogError($"Error processing message: {ex.Message}, event id: {channel} {entry.Id}\r\n{ex}");
+                // Slow down the consumer if there are errors
+                await Task.Delay(1000 * 10);
             }
         }