From c24c993ad9e1b9c4c3152f27b668a61697422501 Mon Sep 17 00:00:00 2001 From: Tom Hayward Date: Wed, 12 Oct 2022 10:10:30 -0700 Subject: [PATCH] fix: crash due to nil msg.Ctx. Fixes #177 Used the same solution as #153 --- redisq/queue.go | 1 + 1 file changed, 1 insertion(+) diff --git a/redisq/queue.go b/redisq/queue.go index 7568e34..9ed9f2b 100644 --- a/redisq/queue.go +++ b/redisq/queue.go @@ -208,6 +208,7 @@ func (q *Queue) ReserveN( for i := range stream.Messages { xmsg := &stream.Messages[i] msg := &msgs[i] + msg.Ctx = ctx err = unmarshalMessage(msg, xmsg) if err != nil {