[camel-quarkus] branch master updated: Fix Twitter itest to wait for latest sent message

[ppalaga]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new f251bbf  Fix Twitter itest to wait for latest sent message
f251bbf is described below

commit f251bbf028d48f970b5bf79b867ebdd3cb055402
Author: Lukas Lowinger <llowi...@redhat.com>
AuthorDate: Mon Aug 31 10:46:35 2020 +0200

    Fix Twitter itest to wait for latest sent message
---
 .../apache/camel/quarkus/component/twitter/CamelResource.java |  3 ++-
 .../camel/quarkus/component/twitter/CamelTwitterTest.java     | 11 ++++++-----
 2 files changed, 8 insertions(+), 6 deletions(-)

diff --git 
a/integration-tests/twitter/src/main/java/org/apache/camel/quarkus/component/twitter/CamelResource.java
 
b/integration-tests/twitter/src/main/java/org/apache/camel/quarkus/component/twitter/CamelResource.java
index d46d3b9..00024eb 100644
--- 
a/integration-tests/twitter/src/main/java/org/apache/camel/quarkus/component/twitter/CamelResource.java
+++ 
b/integration-tests/twitter/src/main/java/org/apache/camel/quarkus/component/twitter/CamelResource.java
@@ -93,7 +93,8 @@ public class CamelResource {
     public String getDirectmessages() {
         LOG.infof("Polling direct messages of user '%s'", twitterUserName);
         final String result = consumerTemplate.receiveBodyNoWait(
-                
String.format("twitter-directmessage://%s?count=16&type=polling&delay=3000", 
twitterUserName), String.class);
+                
String.format("twitter-directmessage://%s?count=16&type=polling&delay=3000&sortById=false",
 twitterUserName),
+                String.class);
         LOG.infof("Received direct messages: %s", result);
         return result;
     }
diff --git 
a/integration-tests/twitter/src/test/java/org/apache/camel/quarkus/component/twitter/CamelTwitterTest.java
 
b/integration-tests/twitter/src/test/java/org/apache/camel/quarkus/component/twitter/CamelTwitterTest.java
index 19c2897..14e26ac 100644
--- 
a/integration-tests/twitter/src/test/java/org/apache/camel/quarkus/component/twitter/CamelTwitterTest.java
+++ 
b/integration-tests/twitter/src/test/java/org/apache/camel/quarkus/component/twitter/CamelTwitterTest.java
@@ -31,7 +31,7 @@ import 
org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
 public class CamelTwitterTest {
 
     @Test
-    public void direct() {
+    public void direct() throws InterruptedException {
         final String uuid = UUID.randomUUID().toString().replace("-", "");
         final String msg = String.format("Direct message from 
camel-quarkus-twitter %s", uuid);
         /* Direct message */
@@ -40,13 +40,15 @@ public class CamelTwitterTest {
                 .then().statusCode(201);
 
         /* Check that the above message or a message sent by a previous run of 
this test was polled by the consumer. */
+        final int initialDelayMs = 60000;
         final int retries = 5;
         final int delayMs = 3000;
         String body = null;
         boolean passed = false;
+        Thread.sleep(initialDelayMs);
         for (int i = 0; i < retries; i++) {
             body = RestAssured.get("/twitter/directmessage").asString();
-            if (body.contains("camel-quarkus-twitter")) {
+            if (body.contains(msg)) {
                 /* test passed */
                 passed = true;
                 break;
@@ -60,8 +62,8 @@ public class CamelTwitterTest {
             }
         }
         if (!passed) {
-            Assertions.fail("Could not find a message containing 
'camel-quarkus-twitter' in user's direct messages within ~"
-                    + (retries * delayMs) + " ms; got messages: " + body);
+            Assertions.fail("Could not find a message containing " + msg + " 
in user's direct messages within ~"
+                    + initialDelayMs + (retries * delayMs) + " ms; got 
messages: " + body);
         }
     }
 
@@ -134,5 +136,4 @@ public class CamelTwitterTest {
             }
         }
     }
-
 }