32
32
import com .amazonaws .services .s3 .model .GetObjectRequest ;
33
33
import com .amazonaws .services .s3 .model .ObjectMetadata ;
34
34
import com .amazonaws .services .s3 .model .PutObjectRequest ;
35
+ import com .amazonaws .services .s3 .model .PutObjectResult ;
35
36
import com .amazonaws .services .s3 .model .S3Object ;
36
37
import com .amazonaws .services .s3 .model .S3ObjectInputStream ;
37
38
import com .amazonaws .services .sqs .AmazonSQS ;
@@ -1335,7 +1336,7 @@ private void storeTextInS3(String s3Key, String messageContentStr, Long messageC
1335
1336
PutObjectRequest putObjectRequest = new PutObjectRequest (clientConfiguration .getS3BucketName (), s3Key ,
1336
1337
messageContentStream , messageContentStreamMetadata );
1337
1338
try {
1338
- clientConfiguration . getAmazonS3Client (). putObject (putObjectRequest );
1339
+ putObject (putObjectRequest );
1339
1340
} catch (AmazonServiceException e ) {
1340
1341
String errorMessage = "Failed to store the message content in an S3 object. SQS message was not sent." ;
1341
1342
LOG .error (errorMessage , e );
@@ -1347,6 +1348,10 @@ private void storeTextInS3(String s3Key, String messageContentStr, Long messageC
1347
1348
}
1348
1349
}
1349
1350
1351
+ protected PutObjectResult putObject (PutObjectRequest var1 ) {
1352
+ return clientConfiguration .getAmazonS3Client ().putObject (var1 );
1353
+ }
1354
+
1350
1355
private static long getStringSizeInBytes (String str ) {
1351
1356
CountingOutputStream counterOutputStream = new CountingOutputStream ();
1352
1357
try {
0 commit comments