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 ef1653f1138 Fix flaky test on CI
ef1653f1138 is described below
commit ef1653f11388149b17fe955f32ccba71b46a04bd
Author: Claus Ibsen <[email protected]>
AuthorDate: Sat Sep 28 19:45:17 2024 +0200
Fix flaky test on CI
---
.../camel/component/file/FileConsumerCommitRenameStrategyTest.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerCommitRenameStrategyTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerCommitRenameStrategyTest.java
index 8565be81dc7..c358af33c5b 100644
---
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerCommitRenameStrategyTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerCommitRenameStrategyTest.java
@@ -40,6 +40,8 @@ public class FileConsumerCommitRenameStrategyTest extends
ContextTestSupport {
template.sendBodyAndHeader(fileUri("reports"), "Hello Paris",
Exchange.FILE_NAME, "paris.txt");
+ context.getRouteController().startAllRoutes();
+
// wait a bit to give the filesystem time to complete the operation
before checking the result
mock.assertIsSatisfied(1000L);
}
@@ -58,6 +60,7 @@ public class FileConsumerCommitRenameStrategyTest extends
ContextTestSupport {
mock.expectedBodiesReceived("Hello London");
template.sendBodyAndHeader(fileUri("reports"), "Hello London",
Exchange.FILE_NAME, "london.txt");
+ context.getRouteController().startAllRoutes();
mock.assertIsSatisfied();
@@ -72,7 +75,8 @@ public class FileConsumerCommitRenameStrategyTest extends
ContextTestSupport {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
-
from(fileUri("reports?move=../done/${file:name}&initialDelay=0&delay=10")).convertBodyTo(String.class)
+
from(fileUri("reports?move=../done/${file:name}&initialDelay=0&delay=10")).autoStartup(false)
+ .convertBodyTo(String.class)
.to("mock:report");
}
};