Bump quarkus.version from 3.14.3 to 3.15.1 (#194)

* Bump quarkus.version from 3.14.3 to 3.15.1 Bumps `quarkus.version` from 3.14.3 to 3.15.1. Updates `io.quarkus:quarkus-bom` from 3.14.3 to 3.15.1 - [Release notes](https://github.com/quarkusio/quarkus/releases) - [Commits](quarkusio/quarkus@3.14.3...3.15.1) Updates `io.quarkus:quarkus-maven-plugin` from 3.14.3 to 3.15.1 Updates `io.quarkus:quarkus-extension-processor` from 3.14.3 to 3.15.1 Updates `io.quarkus:quarkus-extension-maven-plugin` from 3.14.3 to 3.15.1 - [Release notes](https://github.com/quarkusio/quarkus/releases) - [Commits](quarkusio/quarkus@3.14.3...3.15.1) --- updated-dependencies: - dependency-name: io.quarkus:quarkus-bom dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: io.quarkus:quarkus-maven-plugin dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: io.quarkus:quarkus-extension-processor dependency-type: direct:production update-type: version-update:semver-minor - dependency-name: io.quarkus:quarkus-extension-maven-plugin dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> * Fixed deprecated method * Fixed exception when no message * Fixed health check --------- Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Paw Figgé Kjeldgaard <[email protected]>
quarkiverse · Sep 30, 2024 · 12a5fea · 12a5fea
1 parent 67f0de1
commit 12a5fea
Show file tree

Hide file tree

Showing 8 changed files with 15 additions and 14 deletions.
diff --git a/.github/project.yml b/.github/project.yml
@@ -1,4 +1,4 @@
 release:
-  current-version: "1.13.3"
-  next-version: "1.14.0-SNAPSHOT"
+  current-version: "1.14.0"
+  next-version: "1.15.0-SNAPSHOT"
 
diff --git a/...saging/nats/jetstream/deployment/ReactiveMesssagingNatsJetstreamDevServicesProcessor.java b/...saging/nats/jetstream/deployment/ReactiveMesssagingNatsJetstreamDevServicesProcessor.java
@@ -138,7 +138,7 @@ private RunningDevService startJetStreamContainer(DockerStatusBuildItem dockerSt
             return null;
         }
 
-        if (!dockerStatusBuildItem.isDockerAvailable()) {
+        if (!dockerStatusBuildItem.isContainerRuntimeAvailable()) {
             logger.warn("Docker isn't working, please configure the NATS JetStream broker location.");
             return null;
         }

diff --git a/...verse/reactive/messaging/nats/jetstream/test/ReactiveMesssagingNatsJetstreamPushTest.java b/...verse/reactive/messaging/nats/jetstream/test/ReactiveMesssagingNatsJetstreamPushTest.java
@@ -14,6 +14,7 @@
 import org.junit.jupiter.api.extension.RegisterExtension;
 
 import io.quarkus.test.QuarkusUnitTest;
+import io.restassured.filter.log.RequestLoggingFilter;
 import io.restassured.parsing.Parser;
 
 public class ReactiveMesssagingNatsJetstreamPushTest {
@@ -37,8 +38,8 @@ public void setup() {
 
     @Test
     public void health() {
-        given().get("/q/health/ready").then().statusCode(200);
-        given().get("/q/health/live").then().statusCode(200);
+        given().filters(new RequestLoggingFilter(), new RequestLoggingFilter()).get("/q/health/ready").then().statusCode(200);
+        given().filters(new RequestLoggingFilter(), new RequestLoggingFilter()).get("/q/health/live").then().statusCode(200);
     }
 
     @Test

diff --git a/docs/modules/ROOT/pages/includes/attributes.adoc b/docs/modules/ROOT/pages/includes/attributes.adoc
@@ -1,3 +1,3 @@
-:project-version: 1.13.3
+:project-version: 1.14.0
 
 :examples-dir: ./../examples/
diff --git a/pom.xml b/pom.xml
@@ -27,7 +27,7 @@
         <maven.compiler.release>17</maven.compiler.release>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-        <quarkus.version>3.14.3</quarkus.version>
+        <quarkus.version>3.15.1</quarkus.version>
 
         <jnats.version>2.20.2</jnats.version>
         <eddsa.version>0.3.0</eddsa.version>

diff --git a/...java/io/quarkiverse/reactive/messaging/nats/jetstream/client/vertx/MessageConnection.java b/...java/io/quarkiverse/reactive/messaging/nats/jetstream/client/vertx/MessageConnection.java
@@ -234,21 +234,21 @@ private <T> Uni<ConsumerContext> handleConsumerContextFailure(final FetchConsume
 
     private Uni<io.nats.client.Message> nextMessage(final ConsumerContext consumerContext,
             final Duration timeout) {
-        return Uni.createFrom().item(Unchecked.supplier(() -> {
+        return Uni.createFrom().<io.nats.client.Message> emitter(emitter -> {
             try {
                 try (final var fetchConsumer = fetchConsumer(consumerContext, timeout)) {
                     final var message = fetchConsumer.nextMessage();
                     if (message != null) {
-                        return message;
+                        emitter.complete(message);
                     } else {
-                        throw new MessageNotFoundException();
+                        emitter.fail(new MessageNotFoundException());
                     }
                 }
             } catch (Throwable failure) {
                 logger.errorf(failure, "Failed to fetch message: %s", failure.getMessage());
-                throw new FetchException(failure);
+                emitter.fail(new FetchException(failure));
             }
-        }))
+        })
                 .emitOn(context::runOnContext);
     }
 

diff --git a/...reactive/messaging/nats/jetstream/processors/publisher/MessagePullPublisherProcessor.java b/...reactive/messaging/nats/jetstream/processors/publisher/MessagePullPublisherProcessor.java
@@ -28,7 +28,7 @@ public MessagePullPublisherProcessor(final ConnectionFactory connectionFactory,
             final MessagePullPublisherConfiguration<?> configuration) {
         this.configuration = configuration;
         this.connectionFactory = connectionFactory;
-        this.status = new AtomicReference<>(new Status(false, "Not connected", ConnectionEvent.Closed));
+        this.status = new AtomicReference<>(new Status(true, "Not connected", ConnectionEvent.Closed));
         this.connection = new AtomicReference<>();
         this.connectionConfiguration = connectionConfiguration;
     }

diff --git a/...reactive/messaging/nats/jetstream/processors/publisher/MessagePushPublisherProcessor.java b/...reactive/messaging/nats/jetstream/processors/publisher/MessagePushPublisherProcessor.java
@@ -32,7 +32,7 @@ public MessagePushPublisherProcessor(final ConnectionFactory connectionFactory,
         this.connectionConfiguration = connectionConfiguration;
         this.configuration = configuration;
         this.connectionFactory = connectionFactory;
-        this.status = new AtomicReference<>(new Status(false, "Not connected", ConnectionEvent.Closed));
+        this.status = new AtomicReference<>(new Status(true, "Not connected", ConnectionEvent.Closed));
         this.optionsFactory = new PushSubscribeOptionsFactory();
         this.connection = new AtomicReference<>();
     }