Receive Batch Manager Implemetation

Author: joviegas

services/sqs/src/main/java/software/amazon/awssdk/services/sqs/batchmanager/AsyncReceiveMessageBatch.java renamed to services/sqs/src/main/java/software/amazon/awssdk/services/sqs/internal/batchmanager/AsyncReceiveMessageBatch.java

@@ -13,7 +13,7 @@
  * permissions and limitations under the License.
  */
 
-package software.amazon.awssdk.services.sqs.batchmanager;
+package software.amazon.awssdk.services.sqs.internal.batchmanager;
 
 
 import java.time.Duration;
@@ -28,7 +28,6 @@
 import java.util.stream.IntStream;
 import software.amazon.awssdk.annotations.SdkInternalApi;
 import software.amazon.awssdk.services.sqs.SqsAsyncClient;
-import software.amazon.awssdk.services.sqs.internal.batchmanager.ResponseBatchConfiguration;
 import software.amazon.awssdk.services.sqs.model.ChangeMessageVisibilityBatchRequest;
 import software.amazon.awssdk.services.sqs.model.ChangeMessageVisibilityBatchRequestEntry;
 import software.amazon.awssdk.services.sqs.model.ChangeMessageVisibilityBatchResponse;

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

@@ -20,8 +20,6 @@
 import java.util.concurrent.ScheduledExecutorService;
 import software.amazon.awssdk.annotations.SdkInternalApi;
 import software.amazon.awssdk.services.sqs.SqsAsyncClient;
-import software.amazon.awssdk.services.sqs.batchmanager.ReceiveMessageCompletableFuture;
-import software.amazon.awssdk.services.sqs.batchmanager.ReceiveQueueBuffer;
 import software.amazon.awssdk.services.sqs.model.ReceiveMessageRequest;
 import software.amazon.awssdk.services.sqs.model.ReceiveMessageResponse;
 

services/sqs/src/main/java/software/amazon/awssdk/services/sqs/batchmanager/ReceiveMessageCompletableFuture.java renamed to services/sqs/src/main/java/software/amazon/awssdk/services/sqs/internal/batchmanager/ReceiveMessageCompletableFuture.java

@@ -13,7 +13,7 @@
  * permissions and limitations under the License.
  */
 
-package software.amazon.awssdk.services.sqs.batchmanager;
+package software.amazon.awssdk.services.sqs.internal.batchmanager;
 
 import java.time.Duration;
 import java.util.concurrent.CompletableFuture;

services/sqs/src/main/java/software/amazon/awssdk/services/sqs/batchmanager/ReceiveQueueBuffer.java renamed to services/sqs/src/main/java/software/amazon/awssdk/services/sqs/internal/batchmanager/ReceiveQueueBuffer.java

@@ -13,7 +13,7 @@
  * permissions and limitations under the License.
  */
 
-package software.amazon.awssdk.services.sqs.batchmanager;
+package software.amazon.awssdk.services.sqs.internal.batchmanager;
 
 import java.util.LinkedList;
 import java.util.List;
@@ -26,8 +26,6 @@
 import java.util.concurrent.locks.ReentrantLock;
 import software.amazon.awssdk.annotations.SdkInternalApi;
 import software.amazon.awssdk.services.sqs.SqsAsyncClient;
-import software.amazon.awssdk.services.sqs.internal.batchmanager.QueueAttributesManager;
-import software.amazon.awssdk.services.sqs.internal.batchmanager.ResponseBatchConfiguration;
 import software.amazon.awssdk.services.sqs.model.Message;
 import software.amazon.awssdk.services.sqs.model.ReceiveMessageResponse;
 

services/sqs/src/test/java/software/amazon/awssdk/services/sqs/BatchManager/AsyncReceiveMessageBatchTest.java

@@ -46,7 +46,7 @@
 import org.mockito.Mock;
 import org.mockito.junit.jupiter.MockitoExtension;
 import software.amazon.awssdk.services.sqs.SqsAsyncClient;
-import software.amazon.awssdk.services.sqs.batchmanager.AsyncReceiveMessageBatch;
+import software.amazon.awssdk.services.sqs.internal.batchmanager.AsyncReceiveMessageBatch;
 import software.amazon.awssdk.services.sqs.batchmanager.BatchOverrideConfiguration;
 import software.amazon.awssdk.services.sqs.internal.batchmanager.ResponseBatchConfiguration;
 import software.amazon.awssdk.services.sqs.model.ChangeMessageVisibilityBatchRequest;

services/sqs/src/test/java/software/amazon/awssdk/services/sqs/BatchManager/ReceiveQueueBufferTest.java

@@ -45,8 +45,8 @@
 
 import software.amazon.awssdk.services.sqs.SqsAsyncClient;
 import software.amazon.awssdk.services.sqs.batchmanager.BatchOverrideConfiguration;
-import software.amazon.awssdk.services.sqs.batchmanager.ReceiveMessageCompletableFuture;
-import software.amazon.awssdk.services.sqs.batchmanager.ReceiveQueueBuffer;
+import software.amazon.awssdk.services.sqs.internal.batchmanager.ReceiveMessageCompletableFuture;
+import software.amazon.awssdk.services.sqs.internal.batchmanager.ReceiveQueueBuffer;
 import software.amazon.awssdk.services.sqs.internal.batchmanager.QueueAttributesManager;
 import software.amazon.awssdk.services.sqs.internal.batchmanager.ResponseBatchConfiguration;
 import software.amazon.awssdk.services.sqs.model.ChangeMessageVisibilityBatchRequest;