Remove randomness from VT messaging tests

Re-enable VT JMS test

Author: ozangunalp

integration-tests/virtual-threads/amqp-virtual-threads/src/main/java/io/quarkus/it/vthreads/amqp/PriceConsumer.java

@@ -28,9 +28,7 @@ public CompletionStage<Void> consume(Message<Double> msg) {
         assertThatItRunsOnVirtualThread();
         assertThatItRunsOnADuplicatedContext();
         double price = msg.getPayload();
-        if (price > 90.0) {
-            alertService.alertMessage(price);
-        }
+        alertService.alertMessage(price);
         return msg.ack().thenAccept(x -> {
             assertThatItRunsOnADuplicatedContext();
             // While the ack always runs on event loop thread
@@ -43,9 +41,7 @@ public CompletionStage<Void> consume(Message<Double> msg) {
     public void consume(double price) {
         assertThatItRunsOnVirtualThread();
         assertThatItRunsOnADuplicatedContext();
-        if (price > 90.0) {
-            alertService.alert(price);
-        }
+        alertService.alert(price);
     }
 
     Random r = new Random();

integration-tests/virtual-threads/amqp-virtual-threads/src/test/java/io/quarkus/it/vthreads/amqp/WireMockExtension.java

@@ -24,7 +24,7 @@ public Map<String, String> start() {
         wireMockServer.stubFor(post(urlEqualTo("/price/alert-message"))
                 .willReturn(aResponse().withBody("ok")));
 
-        return Map.of("price-alert/mp-rest/url", wireMockServer.baseUrl());
+        return Map.of("quarkus.rest-client.price-alert.url", wireMockServer.baseUrl());
     }
 
     @Override

integration-tests/virtual-threads/jms-virtual-threads/pom.xml

@@ -33,10 +33,11 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-smallrye-reactive-messaging</artifactId>
         </dependency>
+        <!-- JMS connector not part of the Quarkus BOM -->
         <dependency>
             <groupId>io.smallrye.reactive</groupId>
             <artifactId>smallrye-reactive-messaging-jms</artifactId>
-            <version>4.9.0</version>
+            <version>4.10.1</version>
         </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
@@ -144,18 +145,6 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-surefire-plugin</artifactId>
-                <configuration>
-                    <!-- Flaky test -->
-                    <skip>true</skip>
-                </configuration>
-            </plugin>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-failsafe-plugin</artifactId>
-                <configuration>
-                    <!-- Flaky test -->
-                    <skip>true</skip>
-                </configuration>
             </plugin>
         </plugins>
     </build>

integration-tests/virtual-threads/jms-virtual-threads/src/main/java/io/quarkus/it/vthreads/jms/PriceConsumer.java

@@ -1,6 +1,5 @@
 package io.quarkus.it.vthreads.jms;
 
-import static io.quarkus.it.vthreads.jms.AssertHelper.assertThatItDoesNotRunOnVirtualThread;
 import static io.quarkus.it.vthreads.jms.AssertHelper.assertThatItRunsOnVirtualThread;
 
 import java.util.Random;
@@ -27,19 +26,15 @@ public class PriceConsumer {
     public CompletionStage<Void> consume(Message<Double> msg) {
         assertThatItRunsOnVirtualThread();
         double price = msg.getPayload();
-        if (price > 90.0) {
-            alertService.alertMessage(price);
-        }
-        return msg.ack().thenAccept(x -> assertThatItDoesNotRunOnVirtualThread());
+        alertService.alertMessage(price);
+        return msg.ack();
     }
 
     @Incoming("prices")
     @RunOnVirtualThread
     public void consume(double price) {
         assertThatItRunsOnVirtualThread();
-        if (price > 90.0) {
-            alertService.alert(price);
-        }
+        alertService.alert(price);
     }
 
     Random r = new Random();

integration-tests/virtual-threads/kafka-virtual-threads/pom.xml

@@ -81,7 +81,8 @@
                     <artifactId>*</artifactId>
                 </exclusion>
             </exclusions>
-        </dependency>        <dependency>
+        </dependency>
+        <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-rest-client-reactive-deployment</artifactId>
             <version>${project.version}</version>

integration-tests/virtual-threads/kafka-virtual-threads/src/main/java/io/quarkus/it/vthreads/kafka/PriceConsumer.java

@@ -28,9 +28,7 @@ public CompletionStage<Void> consume(Message<Double> msg) {
         assertThatItRunsOnVirtualThread();
         assertThatItRunsOnADuplicatedContext();
         double price = msg.getPayload();
-        if (price > 90.0) {
-            alertService.alertMessage(price);
-        }
+        alertService.alertMessage(price);
         return msg.ack().thenAccept(x -> {
             assertThatItRunsOnADuplicatedContext();
             // While the ack always runs on event loop thread
@@ -43,9 +41,7 @@ public CompletionStage<Void> consume(Message<Double> msg) {
     public void consume(double price) {
         assertThatItRunsOnVirtualThread();
         assertThatItRunsOnADuplicatedContext();
-        if (price > 90.0) {
-            alertService.alert(price);
-        }
+        alertService.alert(price);
     }
 
     Random r = new Random();

integration-tests/virtual-threads/kafka-virtual-threads/src/main/resources/application.properties

@@ -1,4 +1,4 @@
-price-alert/mp-rest/url=${test.url}
+quarkus.rest-client.price-alert.url=${test.url} 
 mp.messaging.incoming.prices.broadcast=true
 mp.messaging.incoming.prices.auto.offset.reset=earliest
 mp.messaging.outgoing.prices-out.topic=prices

integration-tests/virtual-threads/kafka-virtual-threads/src/test/java/io/quarkus/it/vthreads/kafka/WireMockExtension.java

@@ -24,7 +24,7 @@ public Map<String, String> start() {
         wireMockServer.stubFor(post(urlEqualTo("/price/alert-message"))
                 .willReturn(aResponse().withBody("ok")));
 
-        return Map.of("price-alert/mp-rest/url", wireMockServer.baseUrl());
+        return Map.of("quarkus.rest-client.price-alert.url", wireMockServer.baseUrl());
     }
 
     @Override