[camel] 06/06: Camel-AWS2-S3: Better logging

[acosentino]

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

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 09abcfa4e41305cf3b6be25f62629a8546130200
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Apr 2 08:14:30 2021 +0200

    Camel-AWS2-S3: Better logging
---
 .../camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java
 
b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java
index 475fec5..4a4785f 100644
--- 
a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java
+++ 
b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/stream/AWS2S3StreamUploadProducer.java
@@ -137,7 +137,7 @@ public class AWS2S3StreamUploadProducer extends 
DefaultProducer {
                         .key(dynamicKeyName).uploadId(initResponse.uploadId())
                         .partNumber(index.get()).build();
 
-                LOG.trace("Uploading part [{}] for {}", index, keyName);
+                LOG.trace("Uploading part {} at index {} for {}", part, index, 
keyName);
 
                 String etag = getEndpoint().getS3Client()
                         .uploadPart(uploadRequest, 
RequestBody.fromBytes(buffer.toByteArray())).eTag();
@@ -157,6 +157,8 @@ public class AWS2S3StreamUploadProducer extends 
DefaultProducer {
                                 .build();
 
                 CompleteMultipartUploadResponse uploadResult = 
getEndpoint().getS3Client().completeMultipartUpload(compRequest);
+                LOG.trace("Completed upload for the part {} with etag {} at 
index {}", part, uploadResult.eTag(),
+                        index);
                 Message message = getMessageForResponse(exchange);
                 message.setHeader(AWS2S3Constants.E_TAG, uploadResult.eTag());
                 if (uploadResult.versionId() != null) {