Fix ErrorChannel

Author: Oceania2018

src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisSubscriber.cs

@@ -64,21 +64,21 @@ public async Task SubscribeAsync(string channel, string group, int? port, bool p
             {
                 if (priorityEnabled)
                 {
-                    if (await HandleGroupMessage(db, $"{channel}-{EventPriority.High}", group, consumer, received) > 0)
+                    if (await HandleGroupMessage(db, $"{channel}-{EventPriority.High}", group, consumer, received, $"{channel}-Error") > 0)
                     {
                         continue;
                     }
 
-                    if (await HandleGroupMessage(db, $"{channel}-{EventPriority.Medium}", group, consumer, received) > 0)
+                    if (await HandleGroupMessage(db, $"{channel}-{EventPriority.Medium}", group, consumer, received, $"{channel}-Error") > 0)
                     {
                         continue;
                     }
 
-                    await HandleGroupMessage(db, $"{channel}-{EventPriority.Low}", group, consumer, received);
+                    await HandleGroupMessage(db, $"{channel}-{EventPriority.Low}", group, consumer, received, $"{channel}-Error");
                 }
                 else
                 {
-                    await HandleGroupMessage(db, channel, group, consumer, received);
+                    await HandleGroupMessage(db, channel, group, consumer, received, $"{channel}-Error");
                 }
             }
             catch (Exception ex)
@@ -89,7 +89,7 @@ public async Task SubscribeAsync(string channel, string group, int? port, bool p
         }
     }
 
-    private async Task<int> HandleGroupMessage(IDatabase db, string channel, string group, string consumer, Func<string, string, Task> received)
+    private async Task<int> HandleGroupMessage(IDatabase db, string channel, string group, string consumer, Func<string, string, Task> received, string errorChannel)
     {
         var entries = await db.StreamReadGroupAsync(channel, group, consumer, count: 1);
         foreach (var entry in entries)
@@ -106,7 +106,7 @@ private async Task<int> HandleGroupMessage(IDatabase db, string channel, string
                 _logger.LogError($"Error processing message: {ex.Message}, event id: {channel} {entry.Id} {entry.Values[0].Value}");
 
                 // Add a message to the Error stream, keeping only the latest 1 million messages
-                await db.StreamAddAsync($"{channel}-Error",
+                await db.StreamAddAsync(errorChannel,
                     RedisPublisher.AssembleErrorMessage(entry.Values[0].Value, ex.Message),
                     messageId: entry.Id,
                     maxLength: 1000 * 10000);