(camel) branch main updated: Flaky test

[davsclaus]

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

commit e7d2ebce5abd5fe4ffb09a695e54b040635e5dc6
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Nov 16 20:20:28 2024 +0100

    Flaky test
---
 .../java/org/apache/camel/processor/aggregator/AggregatorTest.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorTest.java
 
b/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorTest.java
index cb37d7ae5ed..b6c7e930107 100644
--- 
a/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorTest.java
+++ 
b/core/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorTest.java
@@ -37,7 +37,7 @@ public class AggregatorTest extends ContextTestSupport {
         // lets send a large batch of messages
         for (int i = 1; i <= messageCount; i++) {
             String body = "message:" + i;
-            template.sendBodyAndHeader("direct:start", body, "cheese", 123);
+            template.sendBodyAndHeader("direct:many", body, "cheese", 123);
         }
 
         resultEndpoint.assertIsSatisfied();
@@ -85,6 +85,9 @@ public class AggregatorTest extends ContextTestSupport {
                 // START SNIPPET: ex
                 // in this route we aggregate all from direct:state based on 
the
                 // header id cheese
+                from("direct:many").aggregate(header("cheese"), new 
UseLatestAggregationStrategy()).completionTimeout(2000)
+                        
.completionTimeoutCheckerInterval(100).to("mock:result");
+
                 from("direct:start").aggregate(header("cheese"), new 
UseLatestAggregationStrategy()).completionTimeout(100)
                         
.completionTimeoutCheckerInterval(10).to("mock:result");