in src/main/java/software/amazon/payloadoffloading/S3Dao.java [68:89]
public void storeTextInS3(String s3BucketName, String s3Key, String payloadContentStr) {
PutObjectRequest.Builder putObjectRequestBuilder = PutObjectRequest.builder()
.bucket(s3BucketName)
.key(s3Key);
if (objectCannedACL != null) {
putObjectRequestBuilder.acl(objectCannedACL);
}
// https://docs.aws.amazon.com/AmazonS3/latest/dev/kms-using-sdks.html
if (serverSideEncryptionStrategy != null) {
serverSideEncryptionStrategy.decorate(putObjectRequestBuilder);
}
try {
s3Client.putObject(putObjectRequestBuilder.build(), RequestBody.fromString(payloadContentStr));
} catch (SdkException e) {
String errorMessage = "Failed to store the message content in an S3 object.";
LOG.error(errorMessage, e);
throw SdkException.create(errorMessage, e);
}
}