propagate context to upsertConsumer

Signed-off-by: Rene Kaufmann <[email protected]>
nats-io · Oct 18, 2023 · a1c035f · a1c035f
1 parent ff131ad
commit a1c035f
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/js.go b/js.go
@@ -1727,7 +1727,13 @@ 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)
+
+		opts := make([]JSOpt, 0, 1)
+		if ctx != nil {
+			opts = append(opts, Context(ctx))
+		}
+
+		info, err := js.upsertConsumer(stream, consName, ccreq.Config, opts...)
 		if err != nil {
 			var apiErr *APIError
 			if ok := errors.As(err, &apiErr); !ok {