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 79025e42091 Flaky test
79025e42091 is described below

commit 79025e4209125a184683cc44b7ba5ee963a8686b
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Feb 25 07:42:07 2025 +0100

    Flaky test
---
 .../file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java
index d7f5665ce68..072c790d5d9 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/component/file/FileConsumerBeginAndCommitExpressionRenameStrategyTest.java
@@ -47,12 +47,13 @@ public class 
FileConsumerBeginAndCommitExpressionRenameStrategyTest extends Cont
 
         template.sendBodyAndHeader(fileUri("reports"), "Hello Paris", 
Exchange.FILE_NAME, "paris.txt");
 
+        context.getRouteController().startAllRoutes();
+
         mock.assertIsSatisfied();
     }
 
     @Test
     public void testIllegalOptions() {
-
         Endpoint ep = 
context.getEndpoint(fileUri("?move=../done/${file:name}&delete=true"));
 
         Assertions.assertThrows(IllegalArgumentException.class, () -> 
ep.createConsumer(exchange -> {
@@ -65,6 +66,7 @@ public class 
FileConsumerBeginAndCommitExpressionRenameStrategyTest extends Cont
             public void configure() {
                 from(fileUri(
                         
"reports?preMove=../inprogress/${file:name.noext}.bak&move=../done/${file:name}&initialDelay=0&delay=10"))
+                        .autoStartup(false)
                         .process(new Processor() {
                             @SuppressWarnings("unchecked")
                             public void process(Exchange exchange) {

Reply via email to