[camel-examples] 09/35: CAMEL-16185 - AWS S3: improve multipart support - streaming upload

[dfoulks]

This is an automated email from the ASF dual-hosted git repository.

dfoulks pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-examples.git

commit 2e9b6ff94b57b8393c541fc80200a8803fec618a
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Apr 6 11:08:34 2021 +0200

    CAMEL-16185 - AWS S3: improve multipart support - streaming upload
---
 .../src/main/java/org/apache/camel/example/MyRouteBuilder.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/examples/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
 
b/examples/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
index d46ed3a..5178a22 100644
--- 
a/examples/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
+++ 
b/examples/main-endpointdsl-kafka-aws2-s3/src/main/java/org/apache/camel/example/MyRouteBuilder.java
@@ -28,10 +28,10 @@ public class MyRouteBuilder extends EndpointRouteBuilder {
         
         from(kafka("{{kafkaTopic1}}").brokers("{{kafkaBrokers}}"))
             .log("Kafka Message is: ${body}")
-        
.to(aws2S3("{{bucketName}}").streamMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt"));
+        
.to(aws2S3("{{bucketName}}").streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt"));
 
         from(kafka("{{kafkaTopic2}}").brokers("{{kafkaBrokers}}"))
                 .log("Kafka Message is: ${body}")
-                
.to(aws2S3("{{bucketName}}").streamMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
+                
.to(aws2S3("{{bucketName}}").streamingUploadMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
     }
 }