You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/04/02 06:15:39 UTC
[camel] 06/06: Camel-AWS2-S3: Better logging
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 <an...@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) {