From 2248fe880334ed50d341ab36c6e46a5763c223aa Mon Sep 17 00:00:00 2001
From: Rishiraj Anand <rishiraj.anand1@gmail.com>
Date: Tue, 3 Dec 2024 12:41:54 +0530
Subject: [PATCH] fixing test failure with smallrye-reactive-messaging

---
 build-parent/pom.xml                                      | 6 +++---
 .../drools-quarkus-examples-reactive/pom.xml              | 8 +++++++-
 .../quarkus/ruleunit/examples/reactive/RuntimeTest.java   | 6 ++++++
 drools-reliability/drools-reliability-tests/pom.xml       | 2 +-
 4 files changed, 17 insertions(+), 5 deletions(-)

diff --git a/build-parent/pom.xml b/build-parent/pom.xml
index 52fc0da46bd..4222adc0616 100644
--- a/build-parent/pom.xml
+++ b/build-parent/pom.xml
@@ -67,9 +67,9 @@
     <version.com.miglayout>3.7.4</version.com.miglayout>
     <version.domino-slf4j-logger>1.0.1</version.domino-slf4j-logger>
     <version.com.google.protobuf>3.25.5</version.com.google.protobuf>
-    <version.com.h2database>2.2.220</version.com.h2database>
+    <version.com.h2database>2.3.232</version.com.h2database>
     <version.com.networknt.json-schema-validator>1.0.86</version.com.networknt.json-schema-validator>
-    <version.com.sun.xml.bind>4.0.4</version.com.sun.xml.bind>
+    <version.com.sun.xml.bind>4.0.5</version.com.sun.xml.bind>
     <version.com.thoughtworks.xstream>1.4.21</version.com.thoughtworks.xstream>
     <version.guru.nidi>0.18.0</version.guru.nidi>
     <version.info.picocli>4.7.5</version.info.picocli>
@@ -191,7 +191,7 @@
 
     <version.net.byte-buddy>1.14.11</version.net.byte-buddy>
 
-    <version.org.postgresql>42.7.2</version.org.postgresql>
+    <version.org.postgresql>42.7.4</version.org.postgresql>
 
     <version.ch.obermuhlner>2.0.1</version.ch.obermuhlner>
     <version.io.smallrye.jandex>3.2.2</version.io.smallrye.jandex>
diff --git a/drools-quarkus-extension/drools-quarkus-examples/drools-quarkus-examples-reactive/pom.xml b/drools-quarkus-extension/drools-quarkus-examples/drools-quarkus-examples-reactive/pom.xml
index 7408ab126de..0a35b71415c 100644
--- a/drools-quarkus-extension/drools-quarkus-examples/drools-quarkus-examples-reactive/pom.xml
+++ b/drools-quarkus-extension/drools-quarkus-examples/drools-quarkus-examples-reactive/pom.xml
@@ -51,7 +51,7 @@
     </dependency>
     <dependency>
       <groupId>io.quarkus</groupId>
-      <artifactId>quarkus-smallrye-reactive-messaging-kafka</artifactId>
+      <artifactId>quarkus-messaging-kafka</artifactId>
     </dependency>
     <dependency>
       <groupId>org.assertj</groupId>
@@ -78,6 +78,12 @@
       <scope>test</scope>
     </dependency>
 
+    <dependency>
+      <groupId>org.awaitility</groupId>
+      <artifactId>awaitility</artifactId>
+      <scope>test</scope>
+    </dependency>
+
     <!-- this is used implicitly by quarkus tests so let's make Maven aware 
       of it -->
     <dependency>
diff --git a/drools-quarkus-extension/drools-quarkus-examples/drools-quarkus-examples-reactive/src/test/java/org/drools/quarkus/ruleunit/examples/reactive/RuntimeTest.java b/drools-quarkus-extension/drools-quarkus-examples/drools-quarkus-examples-reactive/src/test/java/org/drools/quarkus/ruleunit/examples/reactive/RuntimeTest.java
index 9771b03d800..b16873e510e 100644
--- a/drools-quarkus-extension/drools-quarkus-examples/drools-quarkus-examples-reactive/src/test/java/org/drools/quarkus/ruleunit/examples/reactive/RuntimeTest.java
+++ b/drools-quarkus-extension/drools-quarkus-examples/drools-quarkus-examples-reactive/src/test/java/org/drools/quarkus/ruleunit/examples/reactive/RuntimeTest.java
@@ -25,9 +25,14 @@
 import io.smallrye.reactive.messaging.memory.InMemoryConnector;
 import io.smallrye.reactive.messaging.memory.InMemorySink;
 import io.smallrye.reactive.messaging.memory.InMemorySource;
+import org.eclipse.microprofile.reactive.messaging.Message;
 import org.eclipse.microprofile.reactive.messaging.spi.Connector;
 import org.junit.jupiter.api.Test;
 
+import java.util.List;
+
+import static org.awaitility.Awaitility.await;
+
 import static org.assertj.core.api.Assertions.assertThat;
 
 @QuarkusTest
@@ -46,6 +51,7 @@ public void sendEvents() {
         incomingEvents.send(new Event("temperature", 20));
         incomingEvents.send(new Event("temperature", 40));
 
+        await().<List<? extends Message<Alert>>>until(outgoingAlerts::received, t -> t.size() == 1);
         assertThat(outgoingAlerts.received().size()).isEqualTo(1);
         assertThat(outgoingAlerts.received().get(0).getPayload().getSeverity()).isEqualTo("warning");
 
diff --git a/drools-reliability/drools-reliability-tests/pom.xml b/drools-reliability/drools-reliability-tests/pom.xml
index c441f6d4e09..da896f97158 100644
--- a/drools-reliability/drools-reliability-tests/pom.xml
+++ b/drools-reliability/drools-reliability-tests/pom.xml
@@ -35,7 +35,7 @@
 
   <properties>
     <java.module.name>org.drools.reliability.infinispan</java.module.name>
-    <version.testcontainers>1.17.2</version.testcontainers>
+    <version.testcontainers>1.20.1</version.testcontainers>
   </properties>
 
   <dependencyManagement>