Merge pull request #7 from jcustovic/content_length_s3

Add content-length value when uploading to S3

Author: jcustovic

README.md

@@ -1,6 +1,6 @@
 The project **Data Exchange Client** allows you to connect to SFTP or FTP servers and configure upload and download pullers.
 
-Current stable version: **1.5.0**
+Current stable version: **1.5.1**
 
 ## How to use
 

pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>com.dataexchange</groupId>
     <artifactId>data-exchange-client</artifactId>
-    <version>1.5.0</version>
+    <version>1.5.1</version>
     <packaging>jar</packaging>
 
     <name>data-exchange-client</name>

src/main/java/com/dataexchange/client/config/flows/S3Flow.java

@@ -45,6 +45,7 @@ public class S3Flow {
 
     public void uploadSetup(String configName, S3Configuration config, String username) {
         IntegrationFlowBuilder s3Flow = IntegrationFlows
+            // TODO add a taskExecutor to poller config for parallel processing
                 .from(Files.inboundAdapter(new File(config.getInputFolder())).preventDuplicates(true).autoCreateDirectory(true),
                         conf -> conf.poller(Pollers.fixedRate(2000).maxMessagesPerPoll(100)))
                 .enrichHeaders(h -> h.headerExpression(FileHeaders.ORIGINAL_FILE, "payload.path"))
@@ -55,6 +56,7 @@ public void uploadSetup(String configName, S3Configuration config, String userna
                     TransferManager tf = TransferManagerBuilder.standard().withS3Client(initS3Client(config)).build();
 
                     ObjectMetadata objectMetadata = new ObjectMetadata();
+                    objectMetadata.setContentLength(payload.length());
                     if (config.getServerSideEncryption()) {
                         objectMetadata.setSSEAlgorithm(ObjectMetadata.AES_256_SERVER_SIDE_ENCRYPTION);
                     }