From a286b0b2d228e96b1ba881efb29ef69c46d31f07 Mon Sep 17 00:00:00 2001 From: Alexander Zavorotynskiy Date: Tue, 25 Oct 2022 18:52:34 +0200 Subject: [PATCH] fix(backend): fixed method call in redis consumer --- backend/pkg/redisstream/consumer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/backend/pkg/redisstream/consumer.go b/backend/pkg/redisstream/consumer.go index fed9a7511..228b2c7a0 100644 --- a/backend/pkg/redisstream/consumer.go +++ b/backend/pkg/redisstream/consumer.go @@ -102,7 +102,7 @@ func (c *Consumer) ConsumeNext() error { return errors.New("Too many messages per ms in redis") } bID := ts<<13 | (idx & 0x1FFF) // Max: 4096 messages/ms for 69 years - c.messageIterator.Iterate([]byte(valueString), messages.NewBatchInfo(sessionID, r.Stream, bID, int64(ts))) + c.messageIterator.Iterate([]byte(valueString), messages.NewBatchInfo(sessionID, r.Stream, bID, 0, int64(ts))) if c.autoCommit { if err = c.redis.XAck(r.Stream, c.group, m.ID).Err(); err != nil { return errors.Wrapf(err, "Acknoledgment error for messageID %v", m.ID)