asynchronously shutdown to decrease delay. (#85)

Author: Robothy

local-s3-interationtest/src/test/java/com/robothy/s3/test/MultiLocalS3InstanceIntegrationTest.java

@@ -1,11 +1,13 @@
 package com.robothy.s3.test;
 
 import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
+
+import com.amazonaws.auth.AWSStaticCredentialsProvider;
+import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.client.builder.AwsClientBuilder;
 import com.amazonaws.services.s3.AmazonS3;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
 import com.amazonaws.services.s3.model.HeadBucketRequest;
-import com.amazonaws.services.s3.transfer.TransferManagerBuilder;
 import com.robothy.s3.rest.LocalS3;
 import com.robothy.s3.rest.bootstrap.LocalS3Mode;
 import java.io.IOException;
@@ -55,6 +57,7 @@ void test() throws IOException {
   AmazonS3 createClient(int port) {
     return AmazonS3ClientBuilder.standard().withEndpointConfiguration(
             new AwsClientBuilder.EndpointConfiguration("http://localhost:" + port, "local"))
+      .withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials("foo", "bar")))
         .enablePathStyleAccess()
         .build();
   }

local-s3-jupiter/src/main/java/com/robothy/s3/jupiter/extensions/AmazonS3Resolver.java

@@ -1,6 +1,8 @@
 package com.robothy.s3.jupiter.extensions;
 
 import com.amazonaws.ClientConfiguration;
+import com.amazonaws.auth.AWSStaticCredentialsProvider;
+import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.client.builder.AwsClientBuilder;
 import com.amazonaws.services.s3.AmazonS3;
 import com.amazonaws.services.s3.AmazonS3Client;
@@ -13,6 +15,7 @@ public class AmazonS3Resolver extends AbstractLocalS3ParameterResolver {
 
   private final AmazonS3ClientBuilder s3Builder = AmazonS3Client.builder()
       .enablePathStyleAccess()
+      .withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials("local-s3-access-key", "local-s3-secret-key")))
       .withClientConfiguration(new ClientConfiguration()
           .withConnectionTimeout(1000)
           .withSocketTimeout(1000));

local-s3-rest/src/main/java/com/robothy/s3/rest/LocalS3.java

@@ -149,17 +149,17 @@ public void shutdown() {
   }
 
   private void shutdownEventExecutorsGroupIfNeeded(EventExecutorGroup... eventExecutorsList) {
+    boolean shutdownPerformed = false;
     for (EventExecutorGroup eventExecutors : eventExecutorsList) {
       if (!eventExecutors.isShuttingDown() && !eventExecutors.isShutdown()) {
-        try {
-          eventExecutors.shutdownGracefully().sync();
-        } catch (InterruptedException e) {
-          throw new RuntimeException(e);
-        }
+        shutdownPerformed = true;
+        eventExecutors.shutdownGracefully();
       }
     }
 
-    log.info("LocalS3 stopped.");
+    if (shutdownPerformed) {
+      log.info("LocalS3 stopped.");
+    }
   }
 
   /**