[FIX] Retry recreating ordered consumer on insufficient resources error

nats-io · Feb 23, 2023 · f086913 · f086913
1 parent edb105c
commit f086913
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/js.go b/js.go
@@ -1989,6 +1989,11 @@ func (sub *Subscription) resetOrderedConsumer(sseq uint64) {
 		}
 
 		if cinfo.Error != nil {
+			if cinfo.Error.ErrorCode == JSErrCodeInsufficientResourcesErr {
+				// retry for insufficient resources, as it may mean that client is connected to a running
+				// server in cluster while the server hosting R1 JetStream resources is restarting
+				return
+			}
 			pushErr(cinfo.Error)
 			return
 		}

diff --git a/jserrors.go b/jserrors.go
@@ -115,6 +115,7 @@ type ErrorCode uint16
 const (
 	JSErrCodeJetStreamNotEnabledForAccount ErrorCode = 10039
 	JSErrCodeJetStreamNotEnabled           ErrorCode = 10076
+	JSErrCodeInsufficientResourcesErr      ErrorCode = 10023
 
 	JSErrCodeStreamNotFound  ErrorCode = 10059
 	JSErrCodeStreamNameInUse ErrorCode = 10058