@@ -81,6 +81,10 @@ public async Task SubscribeAsync(string channel, string group, int? port, bool p
                     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}");
Original file line number	Diff line number	Diff line change
`@@ -81,6 +81,10 @@ public async Task SubscribeAsync(string channel, string group, int? port, bool p`
`81`	`81`	`await HandleGroupMessage(db, channel, group, consumer, received, $"{channel}-Error");`
`82`	`82`	`}`
`83`	`83`	`}`
	`84`	`+ catch (RedisTimeoutException)`
	`85`	`+ {`
	`86`	`+ _logger.LogWarning($"Redis timeout for channel {channel}, will retry in next cycle");`
	`87`	`+ }`
`84`	`88`	`catch (Exception ex)`
`85`	`89`	`{`
`86`	`90`	`_logger.LogError($"Error processing message: {ex.Message}\r\n{ex}");`