SemianiakaVY/BotSharp
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Handle exception SubscribeAsync

Browse source
This commit is contained in:
Haiping Chen 2024-11-23 19:19:24 +00:00
parent 597e26a1e0
commit e92b72ceb5
1 changed files with 17 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
src/Infrastructure/BotSharp.Core/Infrastructures/Events/RedisSubscriber.cs
View file

@ -42,23 +42,30 @@ public class RedisSubscriber : IEventSubscriber
while (true) while (true)
{ {
if (priorityEnabled) try
{ {
if (await HandleGroupMessage(db, $"{channel}-{EventPriority.High}", group, received) > 0) if (priorityEnabled)
{ {
continue; if (await HandleGroupMessage(db, $"{channel}-{EventPriority.High}", group, received) > 0)
} {
continue;
}
if (await HandleGroupMessage(db, $"{channel}-{EventPriority.Medium}", group, received) > 0) if (await HandleGroupMessage(db, $"{channel}-{EventPriority.Medium}", group, received) > 0)
{
continue;
}
await HandleGroupMessage(db, $"{channel}-{EventPriority.Low}", group, received);
}
else
{ {
continue; await HandleGroupMessage(db, channel, group, received);
} }
await HandleGroupMessage(db, $"{channel}-{EventPriority.Low}", group, received);
} }
else catch (Exception ex)
{ {
await HandleGroupMessage(db, channel, group, received); _logger.LogError($"Error processing message: {ex.Message}\r\n{ex}");
} }
} }
} }