Merge pull request #1190 from adenchen123/master

Reapply "Handling redis timeout in RedisSubscriber"
This commit is contained in:
Nick Yi 2025-10-16 11:40:25 +08:00 committed by GitHub
commit 9520aa0747
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -81,6 +81,10 @@ public class RedisSubscriber : IEventSubscriber
await HandleGroupMessage(db, channel, group, consumer, received, $"{channel}-Error");
}
}
catch (RedisTimeoutException)
{
_logger.LogWarning($"Redis timeout for channel {channel}, will retry in next cycle");
}
catch (Exception ex)
{
_logger.LogError($"Error processing message: {ex.Message}\r\n{ex}");