Merge pull request #240 from quarkiverse/bugfix/subscribe

Fixed not closing subscriber when connection lost
quarkiverse · Dec 4, 2024 · d712c12 · d712c12
2 parents 3a7653f + a9cd5d9
commit d712c12
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/.github/project.yml b/.github/project.yml
@@ -1,4 +1,4 @@
 release:
-  current-version: "3.17.0"
+  current-version: "3.17.1"
   next-version: "3.18.0-SNAPSHOT"
 
diff --git a/docs/modules/ROOT/pages/includes/attributes.adoc b/docs/modules/ROOT/pages/includes/attributes.adoc
@@ -1,3 +1,3 @@
-:project-version: 3.17.0
+:project-version: 3.17.1
 
 :examples-dir: ./../examples/
diff --git a/...main/java/io/quarkiverse/reactive/messaging/nats/jetstream/client/ReaderSubscription.java b/...main/java/io/quarkiverse/reactive/messaging/nats/jetstream/client/ReaderSubscription.java
@@ -52,7 +52,7 @@ public Multi<Message<P>> subscribe() {
         ExecutorService pullExecutor = Executors.newSingleThreadExecutor(JetstreamWorkerThread::new);
         return Multi.createBy().repeating()
                 .uni(this::readNextMessage)
-                .whilst(message -> !closed.get())
+                .whilst(message -> true)
                 .runSubscriptionOn(pullExecutor)
                 .emitOn(context::runOnContext)
                 .flatMap(message -> createMulti(message.orElse(null), traceEnabled, payloadType, context));