You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2024/09/02 08:25:03 UTC
(camel) 05/05: CAMEL-21114: camel-zipfile - ZipSplitter with AggregationStrategy does not aggregate all splits in transacted mode.
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 <cl...@gmail.com>
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));
}