This is an automated email from the ASF dual-hosted git repository.
apupier 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 05283e2c5332 Replace deprecated method streamCaching() by
streamCache(true)
05283e2c5332 is described below
commit 05283e2c533219baafd4ef83bc520ce55f65c128
Author: Aurélien Pupier <[email protected]>
AuthorDate: Fri May 29 15:17:54 2026 +0200
Replace deprecated method streamCaching() by streamCache(true)
Signed-off-by: Aurélien Pupier <[email protected]>
---
.../apache/camel/converter/crypto/PGPDataFormatTest.java | 8 ++++----
...fPayloadConsumerNamespaceOnEnvelopeStreamCacheTest.java | 2 +-
...fPayloadProducerNamespaceOnEnvelopeStreamCacheTest.java | 2 +-
.../component/cxf/converter/PayLoadConvertToPOJOTest.java | 2 +-
.../integration/producer/DropboxProducerGetFolderIT.java | 6 +++---
.../camel/component/jetty/JettyWithXPathChoiceTest.java | 2 +-
.../camel/jsonpath/JsonPathBeanStreamCachingTest.java | 2 +-
.../camel/jsonpath/JsonPathStreamCachingCBRTest.java | 6 +++---
.../mime/multipart/MimeMultipartDataFormatTest.java | 2 +-
components/camel-pqc/src/main/docs/pqc-component.adoc | 4 ++--
.../camel/component/xslt/saxon/SAXSourceLogBodyTest.java | 2 +-
.../dataformat/deflater/ZipDeflaterDataFormatTest.java | 2 +-
.../camel/dataformat/zipfile/ZipFileDataFormatTest.java | 2 +-
.../apache/camel/builder/RouteTemplateStreamCacheTest.java | 2 +-
.../bean/BeanParameterBindingStreamCachingTest.java | 2 +-
.../org/apache/camel/component/log/LogInputStreamTest.java | 12 ++++++------
.../apache/camel/component/mock/MockStreamCachingTest.java | 2 +-
.../apache/camel/processor/SplitterStreamCacheTest.java | 2 +-
.../org/apache/camel/processor/StreamCachingInOutTest.java | 8 ++++----
.../apache/camel/processor/StreamCachingOnlyRouteTest.java | 2 +-
.../apache/camel/processor/StreamCachingPerRouteTest.java | 4 ++--
.../StreamSourceContentBasedRouterNoErrorHandlerTest.java | 2 +-
.../processor/StreamSourceContentBasedRouterTest.java | 2 +-
.../apache/camel/processor/TracePerRouteManualTest.java | 2 +-
.../async/AsyncEndpointWithStreamCachingTest.java | 2 +-
.../camel/processor/interceptor/NoStreamCachingTest.java | 6 +++---
.../OnExceptionUseOriginalMessageStreamTest.java | 14 +++++++-------
docs/user-manual/modules/ROOT/pages/stream-caching.adoc | 2 +-
28 files changed, 53 insertions(+), 53 deletions(-)
diff --git
a/components/camel-crypto-pgp/src/test/java/org/apache/camel/converter/crypto/PGPDataFormatTest.java
b/components/camel-crypto-pgp/src/test/java/org/apache/camel/converter/crypto/PGPDataFormatTest.java
index 0f03b442477d..261c24f8c16e 100644
---
a/components/camel-crypto-pgp/src/test/java/org/apache/camel/converter/crypto/PGPDataFormatTest.java
+++
b/components/camel-crypto-pgp/src/test/java/org/apache/camel/converter/crypto/PGPDataFormatTest.java
@@ -588,7 +588,7 @@ public class PGPDataFormatTest extends
AbstractPGPDataFormatTest {
pgpDecryptByteArray.setPassphraseAccessor(passphraseAccessor);
pgpDecryptByteArray.setProvider(getProvider());
-
from("direct:key-ring-byte-array").streamCaching().marshal(pgpEncryptByteArray).to("mock:encrypted")
+
from("direct:key-ring-byte-array").streamCache(true).marshal(pgpEncryptByteArray).to("mock:encrypted")
.unmarshal(pgpDecryptByteArray).to("mock:unencrypted");
// END SNIPPET: pgp-format-key-ring-byte-array
@@ -612,7 +612,7 @@ public class PGPDataFormatTest extends
AbstractPGPDataFormatTest {
pgpVerifyAndDecryptByteArray
.setSignatureVerificationOption(PGPKeyAccessDataFormat.SIGNATURE_VERIFICATION_OPTION_REQUIRED);
- from("direct:sign-key-ring-byte-array").streamCaching()
+ from("direct:sign-key-ring-byte-array").streamCache(true)
// encryption key ring can also be set as header
.setHeader(PGPDataFormat.ENCRYPTION_KEY_RING).constant(getPublicKeyRing())
.marshal(pgpSignAndEncryptByteArray)
@@ -651,7 +651,7 @@ public class PGPDataFormatTest extends
AbstractPGPDataFormatTest {
List<String> expectedSigUserIds = new ArrayList<>();
expectedSigUserIds.add("Second <[email protected]>");
pgpVerifyAndDecryptSeveralSignerKeys.setSignatureKeyUserids(expectedSigUserIds);
-
from("direct:several-signer-keys").streamCaching().marshal(pgpSignAndEncryptSeveralSignerKeys)
+
from("direct:several-signer-keys").streamCache(true).marshal(pgpSignAndEncryptSeveralSignerKeys)
.to("mock:encrypted")
.unmarshal(pgpVerifyAndDecryptSeveralSignerKeys).to("mock:unencrypted");
// END SNIPPET: pgp-format-several-signer-keys
@@ -759,7 +759,7 @@ public class PGPDataFormatTest extends
AbstractPGPDataFormatTest {
pgpVerifyAndDecryptByteArray
.setSignatureVerificationOption(PGPKeyAccessDataFormat.SIGNATURE_VERIFICATION_OPTION_REQUIRED);
-
from("direct:encrypt-sign-without-compressed-data-packet").streamCaching()
+
from("direct:encrypt-sign-without-compressed-data-packet").streamCache(true)
// encryption key ring can also be set as header
.setHeader(PGPDataFormat.ENCRYPTION_KEY_RING).constant(getPublicKeyRing()).marshal(pgpEncryptSign)
// it is recommended to remove the header immediately
when it is no longer needed
diff --git
a/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/CxfPayloadConsumerNamespaceOnEnvelopeStreamCacheTest.java
b/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/CxfPayloadConsumerNamespaceOnEnvelopeStreamCacheTest.java
index a0b8279344df..889d01b0116b 100644
---
a/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/CxfPayloadConsumerNamespaceOnEnvelopeStreamCacheTest.java
+++
b/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/CxfPayloadConsumerNamespaceOnEnvelopeStreamCacheTest.java
@@ -33,7 +33,7 @@ public class
CxfPayloadConsumerNamespaceOnEnvelopeStreamCacheTest extends CxfPay
// The consumer is running in payload mode
from("cxf:bean:serviceEndpoint?dataFormat=PAYLOAD")
// Use stream caching to trigger the issue
- .streamCaching()
+ .streamCache(true)
// Parse to DOM to make sure it's still valid XML
.convertBodyTo(Document.class).setBody().constant(RESPONSE_PAYLOAD);
}
diff --git
a/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/CxfPayloadProducerNamespaceOnEnvelopeStreamCacheTest.java
b/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/CxfPayloadProducerNamespaceOnEnvelopeStreamCacheTest.java
index 5ab362104e1e..84961650cc90 100644
---
a/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/CxfPayloadProducerNamespaceOnEnvelopeStreamCacheTest.java
+++
b/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/CxfPayloadProducerNamespaceOnEnvelopeStreamCacheTest.java
@@ -26,7 +26,7 @@ public class
CxfPayloadProducerNamespaceOnEnvelopeStreamCacheTest extends CxfPay
return new RouteBuilder() {
public void configure() {
from("direct:router") //
- .streamCaching()
+ .streamCache(true)
// call an external Web service in payload mode
.to("cxf:bean:serviceEndpoint?dataFormat=PAYLOAD")
// Check that the issue doesn't occur if stream
caching is enabled
diff --git
a/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java
b/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java
index c48b51f890a0..f57d57fd9463 100644
---
a/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java
+++
b/components/camel-cxf/camel-cxf-spring-soap/src/test/java/org/apache/camel/component/cxf/converter/PayLoadConvertToPOJOTest.java
@@ -70,7 +70,7 @@ public class PayLoadConvertToPOJOTest extends
CamelSpringTestSupport {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
-
from("cxf:bean:routerEndpoint?dataFormat=PAYLOAD").streamCaching().process(new
Processor() {
+
from("cxf:bean:routerEndpoint?dataFormat=PAYLOAD").streamCache(true).process(new
Processor() {
@Override
public void process(Exchange exchange) throws Exception {
diff --git
a/components/camel-dropbox/src/test/java/org/apache/camel/component/dropbox/integration/producer/DropboxProducerGetFolderIT.java
b/components/camel-dropbox/src/test/java/org/apache/camel/component/dropbox/integration/producer/DropboxProducerGetFolderIT.java
index a270cd16b349..59058fadb0dc 100644
---
a/components/camel-dropbox/src/test/java/org/apache/camel/component/dropbox/integration/producer/DropboxProducerGetFolderIT.java
+++
b/components/camel-dropbox/src/test/java/org/apache/camel/component/dropbox/integration/producer/DropboxProducerGetFolderIT.java
@@ -79,7 +79,7 @@ class DropboxProducerGetFolderIT extends DropboxTestSupport {
return new RouteBuilder() {
public void configure() {
from("direct:start")
- .noStreamCaching()
+ .streamCache(false)
.to("dropbox://get?accessToken={{accessToken}}" +
"&expireIn={{expireIn}}" +
"&refreshToken={{refreshToken}}" +
@@ -88,7 +88,7 @@ class DropboxProducerGetFolderIT extends DropboxTestSupport {
.to("mock:result");
from("direct:start2")
- .noStreamCaching()
+ .streamCache(false)
.setHeader(DropboxConstants.HEADER_REMOTE_PATH,
constant(workdir))
.to("dropbox://get?accessToken={{accessToken}}" +
"&expireIn={{expireIn}}" +
@@ -97,7 +97,7 @@ class DropboxProducerGetFolderIT extends DropboxTestSupport {
.to("mock:result");
from("direct:start3")
- .noStreamCaching()
+ .streamCache(false)
.setHeader(DropboxConstants.HEADER_REMOTE_PATH,
constant(workdir))
.to("dropbox://get?accessToken={{accessToken}}" +
"&expireIn={{expireIn}}" +
diff --git
a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyWithXPathChoiceTest.java
b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyWithXPathChoiceTest.java
index 8c7557094122..9b718ca0a5cc 100644
---
a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyWithXPathChoiceTest.java
+++
b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyWithXPathChoiceTest.java
@@ -65,7 +65,7 @@ public class JettyWithXPathChoiceTest extends BaseJettyTest {
public void configure() {
from("jetty:http://localhost:{{port}}/myworld";)
// use stream caching
-
.streamCaching().choice().when().xpath("/one").to("mock:x").when().xpath("/two").to("mock:y")
+
.streamCache(true).choice().when().xpath("/one").to("mock:x").when().xpath("/two").to("mock:y")
.otherwise().to("mock:z").end();
}
diff --git
a/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathBeanStreamCachingTest.java
b/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathBeanStreamCachingTest.java
index c135b9162241..9f311f684e78 100644
---
a/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathBeanStreamCachingTest.java
+++
b/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathBeanStreamCachingTest.java
@@ -41,7 +41,7 @@ public class JsonPathBeanStreamCachingTest extends
CamelTestSupport {
return new RouteBuilder() {
@Override
public void configure() {
- from("direct:start").streamCaching()
+ from("direct:start").streamCache(true)
.bean(FullNameBean.class).to("mock:result");
}
};
diff --git
a/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathStreamCachingCBRTest.java
b/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathStreamCachingCBRTest.java
index ebf4d6a8bbfe..57ef70962ef3 100644
---
a/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathStreamCachingCBRTest.java
+++
b/components/camel-jsonpath/src/test/java/org/apache/camel/jsonpath/JsonPathStreamCachingCBRTest.java
@@ -37,7 +37,7 @@ public class JsonPathStreamCachingCBRTest extends
CamelTestSupport {
context.getStreamCachingStrategy().setSpoolThreshold(-1);
from("direct:start")
- .streamCaching()
+ .streamCache(true)
.choice()
.when().jsonpath("$.store.book[?(@.price < 10)]")
.to("mock:cheap")
@@ -47,7 +47,7 @@ public class JsonPathStreamCachingCBRTest extends
CamelTestSupport {
.to("mock:expensive");
from("direct:bicycle")
- .streamCaching()
+ .streamCache(true)
.choice()
.when().method(new BeanPredicate())
.to("mock:cheap")
@@ -55,7 +55,7 @@ public class JsonPathStreamCachingCBRTest extends
CamelTestSupport {
.to("mock:expensive");
from("direct:bicycle2")
- .streamCaching()
+ .streamCache(true)
.choice()
.when(PredicateBuilder.isLessThan(
ExpressionBuilder.languageExpression("jsonpath", "$.store.bicycle.price"),
diff --git
a/components/camel-mail/src/test/java/org/apache/camel/dataformat/mime/multipart/MimeMultipartDataFormatTest.java
b/components/camel-mail/src/test/java/org/apache/camel/dataformat/mime/multipart/MimeMultipartDataFormatTest.java
index 64134ce94ec5..e7ab99373b88 100644
---
a/components/camel-mail/src/test/java/org/apache/camel/dataformat/mime/multipart/MimeMultipartDataFormatTest.java
+++
b/components/camel-mail/src/test/java/org/apache/camel/dataformat/mime/multipart/MimeMultipartDataFormatTest.java
@@ -551,7 +551,7 @@ public class MimeMultipartDataFormatTest extends
CamelTestSupport {
from("direct:marshalonlymixed").marshal().mimeMultipart();
from("direct:marshalonlyinlineheaders").marshal().mimeMultipart("mixed", false,
true, "(included|x-.*)", false);
from("direct:unmarshalonly").unmarshal().mimeMultipart(false,
false, false);
-
from("direct:unmarshalonlyinlineheaders").streamCaching().unmarshal().mimeMultipart(false,
true, false);
+
from("direct:unmarshalonlyinlineheaders").streamCache(true).unmarshal().mimeMultipart(false,
true, false);
}
};
}
diff --git a/components/camel-pqc/src/main/docs/pqc-component.adoc
b/components/camel-pqc/src/main/docs/pqc-component.adoc
index 7ff27dee5d2d..68acb09534e0 100644
--- a/components/camel-pqc/src/main/docs/pqc-component.adoc
+++ b/components/camel-pqc/src/main/docs/pqc-component.adoc
@@ -2561,7 +2561,7 @@ The DataFormat supports streaming for large payloads,
avoiding memory issues:
[source,java]
--------------------------------------------------------------------------------
from("file:large-files?noop=true")
- .streamCaching() // Enable stream caching if needed
+ .streamCache(true)e) // Enable stream caching if needed
.marshal(pqcFormat)
.to("file:encrypted");
--------------------------------------------------------------------------------
@@ -2646,7 +2646,7 @@ Security.addProvider(new BouncyCastlePQCProvider());
--------------------------------------------------------------------------------
pqcFormat.setBufferSize(16384);
// or
-from("file:large").streamCaching().marshal(pqcFormat)...
+from("file:large.streamCache(true)rue).marshal(pqcFormat)...
--------------------------------------------------------------------------------
=== Dependencies
diff --git
a/components/camel-xslt-saxon/src/test/java/org/apache/camel/component/xslt/saxon/SAXSourceLogBodyTest.java
b/components/camel-xslt-saxon/src/test/java/org/apache/camel/component/xslt/saxon/SAXSourceLogBodyTest.java
index a3925a01de44..78e4b2db2c35 100644
---
a/components/camel-xslt-saxon/src/test/java/org/apache/camel/component/xslt/saxon/SAXSourceLogBodyTest.java
+++
b/components/camel-xslt-saxon/src/test/java/org/apache/camel/component/xslt/saxon/SAXSourceLogBodyTest.java
@@ -49,7 +49,7 @@ public class SAXSourceLogBodyTest extends CamelTestSupport {
return new RouteBuilder() {
@Override
public void configure() {
- from("direct:start").streamCaching()
+ from("direct:start").streamCache(true)
// attach a SaxSource to body
.process(new Processor() {
@Override
diff --git
a/components/camel-zip-deflater/src/test/java/org/apache/camel/dataformat/deflater/ZipDeflaterDataFormatTest.java
b/components/camel-zip-deflater/src/test/java/org/apache/camel/dataformat/deflater/ZipDeflaterDataFormatTest.java
index 6aa2d210de65..b6ee37115ab4 100644
---
a/components/camel-zip-deflater/src/test/java/org/apache/camel/dataformat/deflater/ZipDeflaterDataFormatTest.java
+++
b/components/camel-zip-deflater/src/test/java/org/apache/camel/dataformat/deflater/ZipDeflaterDataFormatTest.java
@@ -139,7 +139,7 @@ public class ZipDeflaterDataFormatTest extends
CamelTestSupport {
context.addRoutes(new RouteBuilder() {
public void configure() {
from("direct:start")
- .streamCaching()
+ .streamCache(true)
.marshal().zipDeflater()
.unmarshal().zipDeflater()
.to("mock:result");
diff --git
a/components/camel-zipfile/src/test/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormatTest.java
b/components/camel-zipfile/src/test/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormatTest.java
index 27f4f578a4a1..e129d1c55366 100644
---
a/components/camel-zipfile/src/test/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormatTest.java
+++
b/components/camel-zipfile/src/test/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormatTest.java
@@ -325,7 +325,7 @@ public class ZipFileDataFormatTest extends CamelTestSupport
{
from("direct:dslZip").marshal().zipFile().to("mock:dslZip");
from("direct:dslUnzip").unmarshal().zipFile().to("mock:dslUnzip");
from("direct:corruptUnzip").unmarshal().zipFile().to("mock:corruptUnzip");
-
from("direct:zipStreamCache").streamCaching().marshal().zipFile().to("mock:zipStreamCache");
+
from("direct:zipStreamCache").streamCache(true).marshal().zipFile().to("mock:zipStreamCache");
ZipFileDataFormat maxDecompressedSizeZip = new
ZipFileDataFormat();
// Only allow 10 bytes to be decompressed
diff --git
a/core/camel-core/src/test/java/org/apache/camel/builder/RouteTemplateStreamCacheTest.java
b/core/camel-core/src/test/java/org/apache/camel/builder/RouteTemplateStreamCacheTest.java
index 5987173bfa16..2f25f1ac051b 100644
---
a/core/camel-core/src/test/java/org/apache/camel/builder/RouteTemplateStreamCacheTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/builder/RouteTemplateStreamCacheTest.java
@@ -37,7 +37,7 @@ public class RouteTemplateStreamCacheTest {
.templateParameter("bar")
.templateParameter("mask")
.route()
- .noStreamCaching()
+ .streamCache(false)
.messageHistory()
.logMask("{{mask}}")
.from("direct:{{foo}}")
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/bean/BeanParameterBindingStreamCachingTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/bean/BeanParameterBindingStreamCachingTest.java
index cccb00ce910f..358c9cf613cf 100644
---
a/core/camel-core/src/test/java/org/apache/camel/component/bean/BeanParameterBindingStreamCachingTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/component/bean/BeanParameterBindingStreamCachingTest.java
@@ -39,7 +39,7 @@ public class BeanParameterBindingStreamCachingTest extends
ContextTestSupport {
return new RouteBuilder() {
@Override
public void configure() {
-
from("direct:start").streamCaching().bean(Foo.class).to("mock:result");
+
from("direct:start").streamCache(true).bean(Foo.class).to("mock:result");
}
};
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/log/LogInputStreamTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/log/LogInputStreamTest.java
index 8d9756b8c6ce..df926feccae3 100644
---
a/core/camel-core/src/test/java/org/apache/camel/component/log/LogInputStreamTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/component/log/LogInputStreamTest.java
@@ -102,17 +102,17 @@ public class LogInputStreamTest extends
ContextTestSupport {
return new RouteBuilder() {
@Override
public void configure() {
- from("direct:a").noStreamCaching().to("log:a").to("mock:a");
+ from("direct:a").streamCache(false).to("log:a").to("mock:a");
-
from("direct:b").noStreamCaching().to("log:b?showStreams=true").to("mock:b");
+
from("direct:b").streamCache(false).to("log:b?showStreams=true").to("mock:b");
- from("direct:c").streamCaching().to("log:c").to("mock:c");
+ from("direct:c").streamCache(true).to("log:c").to("mock:c");
-
from("direct:d").streamCaching().to("log:d?showStreams=true").to("mock:d");
+
from("direct:d").streamCache(true).to("log:d?showStreams=true").to("mock:d");
-
from("direct:e").streamCaching().to("log:e?showCachedStreams=true").to("mock:e");
+
from("direct:e").streamCache(true).to("log:e?showCachedStreams=true").to("mock:e");
-
from("direct:f").streamCaching().to("log:f?showCachedStreams=false").to("mock:f");
+
from("direct:f").streamCache(true).to("log:f?showCachedStreams=false").to("mock:f");
}
};
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/component/mock/MockStreamCachingTest.java
b/core/camel-core/src/test/java/org/apache/camel/component/mock/MockStreamCachingTest.java
index 83d1fec62bf0..838c5323fa11 100644
---
a/core/camel-core/src/test/java/org/apache/camel/component/mock/MockStreamCachingTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/component/mock/MockStreamCachingTest.java
@@ -55,7 +55,7 @@ public class MockStreamCachingTest extends ContextTestSupport
{
return new RouteBuilder() {
@Override
public void configure() {
- from("direct:start").streamCaching().to("mock:result");
+ from("direct:start").streamCache(true).to("mock:result");
}
};
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java
index 31ca1cfdcd04..0c1e919244df 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/SplitterStreamCacheTest.java
@@ -52,7 +52,7 @@ public class SplitterStreamCacheTest extends
ContextTestSupport {
context.getStreamCachingStrategy().setSpoolDirectory(testDirectory().toFile());
context.getStreamCachingStrategy().setSpoolThreshold(-1);
-
from("seda:parallel?concurrentConsumers=5").streamCaching().split(xpath("//person/city")).to("mock:result");
+
from("seda:parallel?concurrentConsumers=5").streamCache(true).split(xpath("//person/city")).to("mock:result");
}
};
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingInOutTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingInOutTest.java
index 7312c3e6e6d0..3572bfac46f0 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingInOutTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingInOutTest.java
@@ -61,10 +61,10 @@ public class StreamCachingInOutTest extends
ContextTestSupport {
@Override
public void configure() {
context.getStreamCachingStrategy().setSpoolThreshold(1);
-
from("direct:c").noStreamCaching().to("direct:d").convertBodyTo(String.class).to("mock:c");
- from("direct:d").streamCaching().process(new TestProcessor());
-
from("direct:e").noStreamCaching().to("direct:f").convertBodyTo(String.class).to("mock:e");
- from("direct:f").streamCaching().process(new TestProcessor());
+
from("direct:c").streamCache(false).to("direct:d").convertBodyTo(String.class).to("mock:c");
+ from("direct:d").streamCache(true).process(new
TestProcessor());
+
from("direct:e").streamCache(false).to("direct:f").convertBodyTo(String.class).to("mock:e");
+ from("direct:f").streamCache(true).process(new
TestProcessor());
}
};
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingOnlyRouteTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingOnlyRouteTest.java
index bfd8a9c2f240..a8dd2322ef6c 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingOnlyRouteTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingOnlyRouteTest.java
@@ -46,7 +46,7 @@ public class StreamCachingOnlyRouteTest extends
ContextTestSupport {
public void configure() {
getContext().getGlobalOptions().put("CamelCachedOutputStreamThreshold", "4096");
- from("direct:c").streamCaching().to("mock:c");
+ from("direct:c").streamCache(true).to("mock:c");
}
};
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingPerRouteTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingPerRouteTest.java
index 204ba758e5b6..8d96c2718b02 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingPerRouteTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamCachingPerRouteTest.java
@@ -71,9 +71,9 @@ public class StreamCachingPerRouteTest extends
ContextTestSupport {
from("direct:a").to("mock:a");
- from("direct:b").noStreamCaching().to("mock:b");
+ from("direct:b").streamCache(false).to("mock:b");
- from("direct:c").streamCaching().to("mock:c");
+ from("direct:c").streamCache(true).to("mock:c");
}
};
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamSourceContentBasedRouterNoErrorHandlerTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamSourceContentBasedRouterNoErrorHandlerTest.java
index c401e420dc90..ee19e507b115 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamSourceContentBasedRouterNoErrorHandlerTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamSourceContentBasedRouterNoErrorHandlerTest.java
@@ -32,7 +32,7 @@ public class StreamSourceContentBasedRouterNoErrorHandlerTest
extends StreamSour
// is enabled and make sure the predicates can be evaluated
// multiple times
-
from("direct:start").streamCaching().choice().when().xpath("/message/text() =
'xx'").to("mock:x").when()
+
from("direct:start").streamCache(true).choice().when().xpath("/message/text() =
'xx'").to("mock:x").when()
.xpath("/message/text() = 'yy'").to("mock:y").end();
}
};
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamSourceContentBasedRouterTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamSourceContentBasedRouterTest.java
index b2064a9648cb..4af26cb325a7 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/StreamSourceContentBasedRouterTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/StreamSourceContentBasedRouterTest.java
@@ -73,7 +73,7 @@ public class StreamSourceContentBasedRouterTest extends
ContextTestSupport {
// is enabled and make sure the predicates can be evaluated
// multiple times
-
from("direct:start").streamCaching().choice().when().xpath("/message/text() =
'xx'").to("mock:x").when()
+
from("direct:start").streamCache(true).choice().when().xpath("/message/text() =
'xx'").to("mock:x").when()
.xpath("/message/text() = 'yy'").to("mock:y");
}
};
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/TracePerRouteManualTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/TracePerRouteManualTest.java
index 0a5ffef51079..3b5a1fdbfda2 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/TracePerRouteManualTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/TracePerRouteManualTest.java
@@ -40,7 +40,7 @@ public class TracePerRouteManualTest extends
ContextTestSupport {
return new RouteBuilder() {
@Override
public void configure() {
- from("direct:a").tracing().streamCaching().to("mock:a");
+ from("direct:a").tracing().streamCache(true).to("mock:a");
from("direct:b").noTracing().to("mock:b");
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithStreamCachingTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithStreamCachingTest.java
index e4b44a1849c7..e9496269dcdb 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithStreamCachingTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/async/AsyncEndpointWithStreamCachingTest.java
@@ -52,7 +52,7 @@ public class AsyncEndpointWithStreamCachingTest extends
ContextTestSupport {
context.addComponent("async", new MyAsyncComponent());
// enable stream caching to ensure it works using async API
-
from("direct:start").streamCaching().tracing().to("mock:before").to("log:before").process(new
Processor() {
+
from("direct:start").streamCache(true).tracing().to("mock:before").to("log:before").process(new
Processor() {
public void process(Exchange exchange) {
beforeThreadName = Thread.currentThread().getName();
}
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/NoStreamCachingTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/NoStreamCachingTest.java
index 426395ee984d..c641f4c85f12 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/NoStreamCachingTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/interceptor/NoStreamCachingTest.java
@@ -53,7 +53,7 @@ public class NoStreamCachingTest extends ContextTestSupport {
context.addRoutes(new RouteBuilder() {
@Override
public void configure() {
- from("direct:a").noStreamCaching().to("mock:a");
+ from("direct:a").streamCache(false).to("mock:a");
}
});
context.start();
@@ -96,9 +96,9 @@ public class NoStreamCachingTest extends ContextTestSupport {
context.addRoutes(new RouteBuilder() {
@Override
public void configure() {
- from("direct:a").noStreamCaching().to("mock:a");
+ from("direct:a").streamCache(false).to("mock:a");
- from("direct:b").streamCaching().to("mock:b");
+ from("direct:b").streamCache(true).to("mock:b");
}
});
context.start();
diff --git
a/core/camel-core/src/test/java/org/apache/camel/processor/onexception/OnExceptionUseOriginalMessageStreamTest.java
b/core/camel-core/src/test/java/org/apache/camel/processor/onexception/OnExceptionUseOriginalMessageStreamTest.java
index 503f7438bf43..83d3526e2b45 100644
---
a/core/camel-core/src/test/java/org/apache/camel/processor/onexception/OnExceptionUseOriginalMessageStreamTest.java
+++
b/core/camel-core/src/test/java/org/apache/camel/processor/onexception/OnExceptionUseOriginalMessageStreamTest.java
@@ -109,30 +109,30 @@ public class OnExceptionUseOriginalMessageStreamTest
extends ContextTestSupport
.convertBodyTo(String.class)
.handled(true);
- from("direct:convertBodyWithStreamCache").streamCaching()
+ from("direct:convertBodyWithStreamCache").streamCache(true)
.convertBodyTo(String.class)
.throwException(new ExceptionOne());
- from("direct:convertBodyWithoutStreamCache").noStreamCaching()
+ from("direct:convertBodyWithoutStreamCache").streamCache(false)
.convertBodyTo(String.class)
.throwException(new ExceptionOne());
- from("direct:unmarshallWithStreamCache").streamCaching()
+ from("direct:unmarshallWithStreamCache").streamCache(true)
.unmarshal(new MyDataFormat())
.throwException(new ExceptionOne());
- from("direct:unmarshallWithoutStreamCache").noStreamCaching()
+ from("direct:unmarshallWithoutStreamCache").streamCache(false)
.unmarshal(new MyDataFormat())
.throwException(new ExceptionOne());
-
from("direct:convertBodyInvalidUnmarshallWithoutStreamCache").noStreamCaching()
+
from("direct:convertBodyInvalidUnmarshallWithoutStreamCache").streamCache(false)
.convertBodyTo(String.class)
.unmarshal(new MyDataFormat());
- from("direct:noStreamReading").streamCaching()
+ from("direct:noStreamReading").streamCache(true)
.throwException(new ExceptionOne());
- from("direct:setBodyAsExchangeProperty").noStreamCaching()
+ from("direct:setBodyAsExchangeProperty").streamCache(false)
.convertBodyTo(String.class)
.setProperty("OriginalBody", body())
.throwException(new ExceptionTwo());
diff --git a/docs/user-manual/modules/ROOT/pages/stream-caching.adoc
b/docs/user-manual/modules/ROOT/pages/stream-caching.adoc
index c3e331d2a88a..e305dd701fd2 100644
--- a/docs/user-manual/modules/ROOT/pages/stream-caching.adoc
+++ b/docs/user-manual/modules/ROOT/pages/stream-caching.adoc
@@ -126,7 +126,7 @@ Java::
[source,java]
----
from("file:inbox")
- .streamCaching()
+ .streamCache(true)
.to("bean:foo");
----
