incremented sequence instead of passing the last seen.

nats-io · Sep 29, 2022 · 5d6dbd1 · 5d6dbd1
1 parent b94c823
commit 5d6dbd1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/nats-base-client/jsclient.ts b/nats-base-client/jsclient.ts
@@ -774,8 +774,8 @@ export class JetStreamSubscriptionImpl extends TypedSubscription<JsMsg>
           return false;
         }
         // reset the consumer
-        const seq = this.info?.ordered_consumer_sequence?.delivery_seq;
-        this._resetOrderedConsumer(seq || 1);
+        const seq = this.info?.ordered_consumer_sequence?.delivery_seq || 0;
+        this._resetOrderedConsumer(seq + 1);
         // if we are ordered, we will reset the consumer and keep
         // feeding the iterator or callback - we are not stopping
         return false;