From b60d47a601be586ec4424a2e50d060e5a098b30c Mon Sep 17 00:00:00 2001
From: scottf <scottfauerbach@gmail.com>
Date: Mon, 11 May 2026 15:50:51 -0400
Subject: [PATCH] Handle consume initial sub failure.

---
 src/main/java/io/nats/client/impl/NatsMessageConsumer.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/main/java/io/nats/client/impl/NatsMessageConsumer.java b/src/main/java/io/nats/client/impl/NatsMessageConsumer.java
index 083d01e74..7fe1516d1 100644
--- a/src/main/java/io/nats/client/impl/NatsMessageConsumer.java
+++ b/src/main/java/io/nats/client/impl/NatsMessageConsumer.java
@@ -160,6 +160,9 @@ void doSub(boolean first) throws JetStreamApiException, IOException {
             rePull();
         }
         catch (JetStreamApiException | IOException e) {
+            if (first) {
+                throw e;
+            }
             resetOnException();
         }
     }