Merge pull request #184 from kd7lxl/fix-nil-ctx

fix crash due to nil msg.Ctx. Fixes #177
vmihailenco · Dec 6, 2022 · 2956d04 · 2956d04
2 parents 2ba5e80 + c24c993
commit 2956d04
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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 {