propagate context to upsertConsumer

nats-io · Oct 5, 2023 · 27fd908 · 27fd908
1 parent ff131ad
commit 27fd908
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/js.go b/js.go
@@ -1727,7 +1727,7 @@ func (js *js) subscribe(subj, queue string, cb MsgHandler, ch chan *Msg, isSync,
 		} else if consName == "" {
 			consName = getHash(nuid.Next())
 		}
-		info, err := js.upsertConsumer(stream, consName, ccreq.Config)
+		info, err := js.upsertConsumer(stream, consName, ccreq.Config, Context(ctx))
 		if err != nil {
 			var apiErr *APIError
 			if ok := errors.As(err, &apiErr); !ok {