public void storeTextInS3()

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);
        }
    }