1+ package me .aneeshneelam .lib .aws .s3 ;
2+
13import com .amazonaws .auth .AWSStaticCredentialsProvider ;
24import com .amazonaws .auth .BasicAWSCredentials ;
35import com .amazonaws .client .builder .AwsClientBuilder ;
46import com .amazonaws .services .s3 .AmazonS3 ;
57import com .amazonaws .services .s3 .AmazonS3ClientBuilder ;
8+ import lombok .extern .java .Log ;
69import me .aneeshneelam .lib .aws .s3 .v1 .S3ObjectSummaryIterator ;
710import me .aneeshneelam .lib .aws .s3 .v2 .AsyncS3ObjectIterator ;
811import me .aneeshneelam .lib .aws .s3 .v2 .S3ObjectIterator ;
3235import java .util .stream .LongStream ;
3336import java .util .stream .StreamSupport ;
3437
35-
38+ @ Log
3639@ Execution (ExecutionMode .CONCURRENT )
3740@ Testcontainers (disabledWithoutDocker = true , parallel = true )
3841public class S3ListObjectsIteratorContainerTest {
@@ -94,12 +97,12 @@ public void setUp() {
9497
9598 if (createS3Bucket ) {
9699 CreateBucketResponse response = this .s3Client .createBucket (r -> r .bucket (s3BucketName ));
97- System . out . println ("Created S3 Bucket, Response: " + response .toString ());
100+ log . info ("Created S3 Bucket, Response: " + response .toString ());
98101 createS3Bucket = false ;
99102 }
100103
101104 if (loadS3Objects ) {
102- System . out . println ("Uploading " + s3ObjectCount + " S3 Objects to Bucket: " + s3BucketName );
105+ log . info ("Uploading " + s3ObjectCount + " S3 Objects to Bucket: " + s3BucketName );
103106 LongStream .rangeClosed (1L , s3ObjectCount ).forEach (i -> {
104107 String key = s3KeyPrefix + String .format (fileNameFormat , i );
105108 String content = String .format (fileContentFormat , i );
@@ -108,16 +111,16 @@ public void setUp() {
108111 .key (key )
109112 .build ();
110113 PutObjectResponse response = this .s3Client .putObject (request , RequestBody .fromString (content , StandardCharsets .UTF_8 ));
111- System . out . println ("Uploaded S3 Object to Bucket: " + s3BucketName + ", Key: " + key + ", Content: " + content + ", Response: " + response .toString ());
114+ log . info ("Uploaded S3 Object to Bucket: " + s3BucketName + ", Key: " + key + ", Content: " + content + ", Response: " + response .toString ());
112115 });
113116 loadS3Objects = false ;
114- System . out . println ("Uploaded " + s3ObjectCount + " S3 Objects to Bucket: " + s3BucketName );
117+ log . info ("Uploaded " + s3ObjectCount + " S3 Objects to Bucket: " + s3BucketName );
115118 }
116119 }
117120
118121 @ Test
119122 public void testS3ObjectIterator () {
120- System . out . println ("Testing: " + S3ObjectIterator .class .getCanonicalName () + " with SDK: " + this .s3Client .getClass ().getCanonicalName ());
123+ log . info ("Testing: " + S3ObjectIterator .class .getCanonicalName () + " with SDK: " + this .s3Client .getClass ().getCanonicalName ());
121124 ListObjectsV2Request listObjectsV2Request = ListObjectsV2Request .builder ()
122125 .bucket (s3BucketName )
123126 .prefix (s3KeyPrefix )
@@ -130,7 +133,7 @@ public void testS3ObjectIterator() {
130133
131134 @ Test
132135 public void testS3ObjectIteratorAsync () {
133- System . out . println ("Testing: " + AsyncS3ObjectIterator .class .getCanonicalName () + " with SDK: " + this .s3AsyncClient .getClass ().getCanonicalName ());
136+ log . info ("Testing: " + AsyncS3ObjectIterator .class .getCanonicalName () + " with SDK: " + this .s3AsyncClient .getClass ().getCanonicalName ());
134137 ListObjectsV2Request listObjectsV2Request = ListObjectsV2Request .builder ()
135138 .bucket (s3BucketName )
136139 .prefix (s3KeyPrefix )
@@ -143,7 +146,7 @@ public void testS3ObjectIteratorAsync() {
143146
144147 @ Test
145148 public void testS3ObjectIteratorAsyncCrt () {
146- System . out . println ("Testing: " + AsyncS3ObjectIterator .class .getCanonicalName () + " with SDK: " + this .s3AsyncCrtClient .getClass ().getCanonicalName ());
149+ log . info ("Testing: " + AsyncS3ObjectIterator .class .getCanonicalName () + " with SDK: " + this .s3AsyncCrtClient .getClass ().getCanonicalName ());
147150 ListObjectsV2Request listObjectsV2Request = ListObjectsV2Request .builder ()
148151 .bucket (s3BucketName )
149152 .prefix (s3KeyPrefix )
@@ -156,7 +159,7 @@ public void testS3ObjectIteratorAsyncCrt() {
156159
157160 @ Test
158161 public void testS3ObjectSummaryIterator () {
159- System . out . println ("Testing: " + S3ObjectSummaryIterator .class .getCanonicalName ()+ " with SDK: " + this .amazonS3 .getClass ().getCanonicalName ());
162+ log . info ("Testing: " + S3ObjectSummaryIterator .class .getCanonicalName ()+ " with SDK: " + this .amazonS3 .getClass ().getCanonicalName ());
160163 com .amazonaws .services .s3 .model .ListObjectsV2Request listObjectsV2Request = new com .amazonaws .services .s3 .model .ListObjectsV2Request ()
161164 .withBucketName (s3BucketName )
162165 .withPrefix (s3KeyPrefix );
0 commit comments