You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2023/08/10 17:00:14 UTC
[camel] branch flaky3 created (now aa2555ea3d9)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch flaky3
in repository https://gitbox.apache.org/repos/asf/camel.git
at aa2555ea3d9 CAMEL-19684: Fix flaky test
This branch includes the following new commits:
new aa2555ea3d9 CAMEL-19684: Fix flaky test
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel] 01/01: CAMEL-19684: Fix flaky test
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch flaky3
in repository https://gitbox.apache.org/repos/asf/camel.git
commit aa2555ea3d9180886d4abfce6a62a56596089338
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Aug 10 19:00:00 2023 +0200
CAMEL-19684: Fix flaky test
---
.../component/file/FileConsumerIdempotentKeyChangedIssue2Test.java | 2 +-
.../camel/impl/engine/DefaultSupervisingRouteControllerTest.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerIdempotentKeyChangedIssue2Test.java b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerIdempotentKeyChangedIssue2Test.java
index 4c81def9bd4..f9171640590 100644
--- a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerIdempotentKeyChangedIssue2Test.java
+++ b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerIdempotentKeyChangedIssue2Test.java
@@ -56,7 +56,7 @@ public class FileConsumerIdempotentKeyChangedIssue2Test extends ContextTestSuppo
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- endpoint = endpoint(fileUri("?noop=true&initialDelay=0&delay=10"
+ endpoint = endpoint(fileUri("?noop=true&initialDelay=0&delay=100"
+ "&idempotentKey=${file:name}-${file:size}-${file:modified}"));
from(endpoint).noAutoStartup().convertBodyTo(String.class).to("log:file").to("mock:file");
diff --git a/core/camel-core/src/test/java/org/apache/camel/impl/engine/DefaultSupervisingRouteControllerTest.java b/core/camel-core/src/test/java/org/apache/camel/impl/engine/DefaultSupervisingRouteControllerTest.java
index 5ee2bdd4714..af5158497e8 100644
--- a/core/camel-core/src/test/java/org/apache/camel/impl/engine/DefaultSupervisingRouteControllerTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/impl/engine/DefaultSupervisingRouteControllerTest.java
@@ -66,7 +66,7 @@ public class DefaultSupervisingRouteControllerTest extends ContextTestSupport {
MockEndpoint mock4 = context.getEndpoint("mock:bar", MockEndpoint.class);
mock4.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(5, TimeUnit.SECONDS, mock, mock2, mock3, mock4);
+ MockEndpoint.assertIsSatisfied(10, TimeUnit.SECONDS, mock, mock2, mock3, mock4);
assertEquals("Started", context.getRouteController().getRouteStatus("foo").toString());
// cheese was not able to start
@@ -110,7 +110,7 @@ public class DefaultSupervisingRouteControllerTest extends ContextTestSupport {
MockEndpoint mock4 = context.getEndpoint("mock:bar", MockEndpoint.class);
mock4.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(5, TimeUnit.SECONDS, mock, mock2, mock3, mock4);
+ MockEndpoint.assertIsSatisfied(10, TimeUnit.SECONDS, mock, mock2, mock3, mock4);
// these should all start
assertEquals("Started", context.getRouteController().getRouteStatus("foo").toString());