This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-4.8.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.8.x by this push:
new 14628956e8a CAMEL-22216: Added unit test
14628956e8a is described below
commit 14628956e8a5606a7c23c1e93c3fdcec7a5e090b
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Jul 4 10:05:33 2025 +0200
CAMEL-22216: Added unit test
---
.../zipfile/ZipSplitAggregateTransactedIssueTest.java | 4 ++--
...ava => ZipSplitAggregateTransactedStreamingIssueTest.java} | 8 +++++---
.../src/main/java/org/apache/camel/model/RouteDefinition.java | 11 +++++++++++
3 files changed, 18 insertions(+), 5 deletions(-)
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 3d9ef361185..dee5cb9f0a6 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
@@ -76,11 +76,11 @@ public class ZipSplitAggregateTransactedIssueTest extends
CamelTestSupport {
getContext().getRegistry().bind("transacted",
springTransactionPolicy);
getContext().getRegistry().bind("zipSplitter", new
ZipSplitter());
- from("direct:start")
+ from("direct:start").streamCache(false)
.transacted("transacted")
.setBody().simple(zipArchiveWithTwoFiles)
.unmarshal().base64()
-
.split().ref("zipSplitter").streaming().aggregationStrategy(new
StringAggregationStrategy())
+ .split().ref("zipSplitter").aggregationStrategy(new
StringAggregationStrategy())
.log("Splitting ${header.CamelFileName}")
.end()
.to("mock:result");
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/ZipSplitAggregateTransactedStreamingIssueTest.java
similarity index 95%
copy from
components/camel-zipfile/src/test/java/org/apache/camel/processor/aggregate/zipfile/ZipSplitAggregateTransactedIssueTest.java
copy to
components/camel-zipfile/src/test/java/org/apache/camel/processor/aggregate/zipfile/ZipSplitAggregateTransactedStreamingIssueTest.java
index 3d9ef361185..a31bfb542d0 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/ZipSplitAggregateTransactedStreamingIssueTest.java
@@ -24,6 +24,7 @@ import org.apache.camel.dataformat.zipfile.ZipSplitter;
import org.apache.camel.spring.spi.SpringTransactionPolicy;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.h2.jdbcx.JdbcDataSource;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -32,9 +33,10 @@ import
org.springframework.transaction.support.TransactionTemplate;
import static org.junit.jupiter.api.Assertions.assertEquals;
-public class ZipSplitAggregateTransactedIssueTest extends CamelTestSupport {
+@Disabled("")
+public class ZipSplitAggregateTransactedStreamingIssueTest extends
CamelTestSupport {
- private static final Logger LOG =
LoggerFactory.getLogger(ZipSplitAggregateTransactedIssueTest.class);
+ private static final Logger LOG =
LoggerFactory.getLogger(ZipSplitAggregateTransactedStreamingIssueTest.class);
String zipArchiveWithTwoFiles
=
"UEsDBBQAAAAIAFlrtFDFAfecUAAAAB4BAAALAAAAT3JkZXJzMS54bWyzyS9KSS0qtuPl4oQwQSxOm8wUOxMb/cwUCK+gKD+lNLkEzOG0yUvMTbWDCik42uiD+WB1+kgKbfThxqEZbEqUwU6kG2xGlMHOhA2GsortAFBLAwQUAAAACABBW9hQgBf0tVgAAAAqAQAACwAAAE9yZGVyczIueG1ss8kvSkktKrbj5eKEMEEsTpvMFDtDQ0Mb/cwUCL+gKD+lNLkEzOG0yUvMTbWDCimA1YFFwCr1kZTa6MONRDPcyMiIKMPB6kg13NjYmCjDweoIGQ5lFdsBAFBLAQIfABQAAAAIAFlrtFDFAfecUAAAAB4BAAALACQAAAAAAAAAIAAAAAAAAABPcmRlcnMxLnhtbAoAIAAAAAAAAQAYAAD57I2ZLtYBg97kuHn02gEA+eyNmS7WAVBLAQIfABQAAAAIAEFb2
[...]
@@ -76,7 +78,7 @@ public class ZipSplitAggregateTransactedIssueTest extends
CamelTestSupport {
getContext().getRegistry().bind("transacted",
springTransactionPolicy);
getContext().getRegistry().bind("zipSplitter", new
ZipSplitter());
- from("direct:start")
+ from("direct:start").streamCache(false)
.transacted("transacted")
.setBody().simple(zipArchiveWithTwoFiles)
.unmarshal().base64()
diff --git
a/core/camel-core-model/src/main/java/org/apache/camel/model/RouteDefinition.java
b/core/camel-core-model/src/main/java/org/apache/camel/model/RouteDefinition.java
index a388b1ba90b..9c39a511a94 100644
---
a/core/camel-core-model/src/main/java/org/apache/camel/model/RouteDefinition.java
+++
b/core/camel-core-model/src/main/java/org/apache/camel/model/RouteDefinition.java
@@ -377,6 +377,17 @@ public class RouteDefinition extends
OutputDefinition<RouteDefinition>
return this;
}
+ /**
+ * Enable or disables stream caching for this route.
+ *
+ * @param streamCache whether to use stream caching
+ * @return the builder
+ */
+ public RouteDefinition streamCache(boolean streamCache) {
+ setStreamCache(streamCache ? "true" : "false");
+ return this;
+ }
+
/**
* Enable or disables stream caching for this route.
*
