This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push: new 55890f182ba CAMEL-19684: Fix flaky test (#11075) 55890f182ba is described below commit 55890f182ba60b280843b693753af9cb55b827e2 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu Aug 10 19:45:36 2023 +0200 CAMEL-19684: Fix flaky test (#11075) --- .../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());