Reapply "Handling redis timeout in RedisSubscriber"

This reverts commit b8636a7c40.
This commit is contained in:
aden.chen 2025-10-16 08:57:21 +08:00
parent 79c6bf7fd3
commit 840ee277ea

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}");