[camel-quarkus] branch main updated: Fixup #2658 Intermittent failures in MongoDbTest.testTailingConsumer() and MongoDbTest.testPersistentTailingConsumer()

[ppalaga]

This is an automated email from the ASF dual-hosted git repository.

ppalaga pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new e4d2f9d  Fixup #2658 Intermittent failures in 
MongoDbTest.testTailingConsumer() and 
MongoDbTest.testPersistentTailingConsumer()
e4d2f9d is described below

commit e4d2f9dd806149afc91d79c41f0d422a357cedf4
Author: Peter Palaga <ppal...@redhat.com>
AuthorDate: Wed Jun 16 11:25:00 2021 +0200

    Fixup #2658 Intermittent failures in MongoDbTest.testTailingConsumer() and 
MongoDbTest.testPersistentTailingConsumer()
---
 .../quarkus/component/mongodb/it/MongoDbTest.java  | 23 +++++++++++++++-------
 1 file changed, 16 insertions(+), 7 deletions(-)

diff --git 
a/integration-tests/mongodb/src/test/java/org/apache/camel/quarkus/component/mongodb/it/MongoDbTest.java
 
b/integration-tests/mongodb/src/test/java/org/apache/camel/quarkus/component/mongodb/it/MongoDbTest.java
index 44312ae..b62dc17 100644
--- 
a/integration-tests/mongodb/src/test/java/org/apache/camel/quarkus/component/mongodb/it/MongoDbTest.java
+++ 
b/integration-tests/mongodb/src/test/java/org/apache/camel/quarkus/component/mongodb/it/MongoDbTest.java
@@ -34,6 +34,7 @@ import org.apache.camel.ServiceStatus;
 import org.apache.camel.util.CollectionHelper;
 import org.bson.Document;
 import org.eclipse.microprofile.config.ConfigProvider;
+import org.jboss.logging.Logger;
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
@@ -53,6 +54,8 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
 @QuarkusTest
 @QuarkusTestResource(MongoDbTestResource.class)
 class MongoDbTest {
+    private static final Logger LOG = Logger.getLogger(MongoDbTest.class);
+
     public static final String MSG = "Hello Camel Quarkus Mongo DB";
     public static final int CAP_NUMBER = 1000;
 
@@ -277,13 +280,19 @@ class MongoDbTest {
     }
 
     private void waitAndResetTailingResults(int expectedSize, String 
laststring, String resultId) {
-        await().atMost(5, TimeUnit.SECONDS).until(
-                () -> RestAssured
-                        .given().contentType(ContentType.JSON)
-                        .get("/mongodb/results/" + resultId)
-                        .then()
-                        .statusCode(200)
-                        .extract().as(Map.class),
+        LOG.info("Awaiting results with size " + expectedSize + " and last 
string " + laststring);
+        await().atMost(30, TimeUnit.SECONDS).until(
+                () -> {
+                    @SuppressWarnings("unchecked")
+                    Map<String, ?> result = (Map<String, ?>) RestAssured
+                            .given().contentType(ContentType.JSON)
+                            .get("/mongodb/results/" + resultId)
+                            .then()
+                            .statusCode(200)
+                            .extract().as(Map.class);
+                    LOG.info("Received results" + result);
+                    return result;
+                },
                 m -> ((int) m.get("size") == expectedSize && 
laststring.equals(((Map) m.get("last")).get("string"))));
 
         RestAssured