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));
     }