jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

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

Browse source
This commit is contained in:
Alexander 2025-05-16 16:58:04 +02:00
parent a460d8c9a2
commit 0926888213
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
backend/pkg/redisstream/consumer.go
View file

@ -80,7 +80,7 @@ func (c *Consumer) ConsumeNext() error {
Consumer: c.group, Consumer: c.group,
Streams: c.streams, Streams: c.streams,
Count: int64(READ_COUNT), Count: int64(READ_COUNT),
Block: 200 * time.Millisecond, Block: 2000 * time.Millisecond,
}).Result() }).Result()
if err != nil { if err != nil {
if err, ok := err.(net.Error); ok && err.Timeout() { if err, ok := err.(net.Error); ok && err.Timeout() {