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 5d58b07c50b Flaky test
5d58b07c50b is described below
commit 5d58b07c50bf6815a2305d05fda2ba70baa3dbf9
Author: Claus Ibsen <[email protected]>
AuthorDate: Sat Oct 5 10:24:12 2024 +0200
Flaky test
---
.../enricher/PollEnrichFileCustomAggregationStrategyTest.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileCustomAggregationStrategyTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileCustomAggregationStrategyTest.java
index 42899098759..0defda6f021 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileCustomAggregationStrategyTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/enricher/PollEnrichFileCustomAggregationStrategyTest.java
@@ -27,7 +27,6 @@ public class PollEnrichFileCustomAggregationStrategyTest
extends ContextTestSupp
@Test
public void testPollEnrichCustomAggregationStrategyBody() throws Exception
{
-
getMockEndpoint("mock:start").expectedBodiesReceived("Start");
MockEndpoint mock = getMockEndpoint("mock:result");
@@ -38,6 +37,8 @@ public class PollEnrichFileCustomAggregationStrategyTest
extends ContextTestSupp
template.sendBodyAndHeader(fileUri("enrich"), "Start",
Exchange.FILE_NAME, "AAA.fin");
+ context.getRouteController().startAllRoutes();
+
log.info("Sleeping for 0.5 sec before writing enrichdata file");
Thread.sleep(500);
template.sendBodyAndHeader(fileUri("enrichdata"), "Big file",
@@ -54,7 +55,7 @@ public class PollEnrichFileCustomAggregationStrategyTest
extends ContextTestSupp
return new RouteBuilder() {
@Override
public void configure() {
- from(fileUri("enrich?initialDelay=0&delay=10&move=.done"))
+
from(fileUri("enrich?initialDelay=0&delay=10&move=.done")).autoStartup(false)
.to("mock:start")
.pollEnrich(
fileUri("enrichdata?initialDelay=0&delay=10&readLock=markerFile&move=.done"),
