This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch zip in repository https://gitbox.apache.org/repos/asf/camel.git
commit 8d639859b6c83b7fdf43ed1d72db52edbc019ce1 Author: Claus Ibsen <[email protected]> AuthorDate: Mon Sep 2 10:24:37 2024 +0200 CAMEL-21114: camel-zipfile - ZipSplitter with AggregationStrategy does not aggregate all splits in transacted mode. --- .../aggregate/zipfile/ZipSplitAggregateTransactedIssueTest.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/components/camel-zipfile/src/test/java/org/apache/camel/processor/aggregate/zipfile/ZipSplitAggregateTransactedIssueTest.java b/components/camel-zipfile/src/test/java/org/apache/camel/processor/aggregate/zipfile/ZipSplitAggregateTransactedIssueTest.java index 7a7c225d85d..3d9ef361185 100644 --- a/components/camel-zipfile/src/test/java/org/apache/camel/processor/aggregate/zipfile/ZipSplitAggregateTransactedIssueTest.java +++ b/components/camel-zipfile/src/test/java/org/apache/camel/processor/aggregate/zipfile/ZipSplitAggregateTransactedIssueTest.java @@ -42,8 +42,11 @@ public class ZipSplitAggregateTransactedIssueTest extends CamelTestSupport { @Test public void testIfAllSplitsAggregated() throws Exception { MockEndpoint mock = getMockEndpoint("mock:result"); + template.sendBody("direct:start", ""); + mock.assertIsSatisfied(); + // Check if second file was processed in aggregate() method of AggregationStrategy assertEquals("Orders2.xml", mock.getExchanges().get(0).getMessage().getHeader("CamelFileName", String.class)); }
