[FIXED] Resetting ordered consumer after context timeout (#1360)

Signed-off-by: Piotr Piotrowski <[email protected]>
nats-io · Aug 22, 2023 · 4a6ed23 · 4a6ed23
1 parent 4ccbf08
commit 4a6ed23
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/js.go b/js.go
@@ -2029,7 +2029,7 @@ func (sub *Subscription) resetOrderedConsumer(sseq uint64) {
 		cinfo, err := js.upsertConsumer(jsi.stream, consName, cfg)
 		if err != nil {
 			var apiErr *APIError
-			if errors.Is(err, ErrJetStreamNotEnabled) || errors.Is(err, ErrTimeout) {
+			if errors.Is(err, ErrJetStreamNotEnabled) || errors.Is(err, ErrTimeout) || errors.Is(err, context.DeadlineExceeded) {
 				// if creating consumer failed, retry
 				return
 			} else if errors.As(err, &apiErr) && apiErr.ErrorCode == JSErrCodeInsufficientResourcesErr {