feat(redis): increased the block duration for read operation

2025-05-16 16:58:04 +02:00
1 changed files with 1 additions and 1 deletions
--- a/backend/pkg/redisstream/consumer.go
+++ b/backend/pkg/redisstream/consumer.go
@ -80,7 +80,7 @@ func (c *Consumer) ConsumeNext() error {
 		Consumer: c.group,
 		Streams:  c.streams,
 		Count:    int64(READ_COUNT),
-		Block:    200 * time.Millisecond,
+		Block:    2000 * time.Millisecond,
 	}).Result()
 	if err != nil {
 		if err, ok := err.(net.Error); ok && err.Timeout() {