SdkClosable implemented

Author: joviegas

services/sqs/src/main/java/software/amazon/awssdk/services/sqs/internal/batchmanager/ReceiveBatchManager.java

@@ -24,9 +24,10 @@
 import software.amazon.awssdk.services.sqs.SqsAsyncClient;
 import software.amazon.awssdk.services.sqs.model.ReceiveMessageRequest;
 import software.amazon.awssdk.services.sqs.model.ReceiveMessageResponse;
+import software.amazon.awssdk.utils.SdkAutoCloseable;
 
 @SdkInternalApi
-public class ReceiveBatchManager {
+public class ReceiveBatchManager implements SdkAutoCloseable {
 
     private final SqsAsyncClient sqsClient;
     private final ScheduledExecutorService executor;
@@ -62,8 +63,8 @@ public CompletableFuture<ReceiveMessageResponse> processRequest(ReceiveMessageRe
         });
     }
 
-    public void shutdown() {
+    @Override
+    public void close() {
         receiveQueueBuffer.shutdown();
-        executor.shutdown();
     }
 }

services/sqs/src/test/java/software/amazon/awssdk/services/sqs/batchmanager/ReceiveBatchManagerTest.java

@@ -165,7 +165,7 @@ public void testShutdown() throws Exception {
         ReceiveMessageRequest request = ReceiveMessageRequest.builder().maxNumberOfMessages(10).build();
         CompletableFuture<ReceiveMessageResponse> futureResponse = receiveBatchManager.processRequest(request);
 
-        receiveBatchManager.shutdown();
+        receiveBatchManager.close();
 
         assertThrows(IllegalStateException.class, () -> receiveBatchManager.processRequest(request));