You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pp...@apache.org on 2020/08/31 16:32:36 UTC
[camel-quarkus] branch master updated: Fix Twitter itest to wait
for latest sent message
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 <ll...@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 {
}
}
}
-
}