Handling redis timeout in RedisSubscriber

This commit is contained in:
aden.chen 2025-10-15 10:20:28 +08:00
parent 800e535231
commit 1184528d70

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