in src/main/java/software/amazon/payloadoffloading/S3Dao.java [38:66]
public String getTextFromS3(String s3BucketName, String s3Key) {
GetObjectRequest getObjectRequest = GetObjectRequest.builder()
.bucket(s3BucketName)
.key(s3Key)
.build();
ResponseInputStream<GetObjectResponse> object = null;
try {
object = s3Client.getObject(getObjectRequest);
} catch (SdkException e) {
String errorMessage = "Failed to get the S3 object which contains the payload.";
LOG.error(errorMessage, e);
throw SdkException.create(errorMessage, e);
}
String embeddedText;
try {
embeddedText = IoUtils.toUtf8String(object);
} catch (IOException e) {
String errorMessage = "Failure when handling the message which was read from S3 object.";
LOG.error(errorMessage, e);
throw SdkClientException.create(errorMessage, e);
} finally {
IoUtils.closeQuietly(object, LOG);
}
return embeddedText;
}