From f0959cb17cd77d6f95a6a16b3267db20d10b6b58 Mon Sep 17 00:00:00 2001 From: Jacob Li Date: Thu, 28 Sep 2023 11:48:57 -0700 Subject: [PATCH] Add SQS ReDrive APIs in the updated model --- .../AmazonSQSExtendedClientBase.java | 77 +++++-------------- 1 file changed, 19 insertions(+), 58 deletions(-) diff --git a/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedClientBase.java b/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedClientBase.java index 8530c6d..a2d8425 100644 --- a/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedClientBase.java +++ b/src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedClientBase.java @@ -23,65 +23,9 @@ import com.amazonaws.auth.AWSCredentialsProvider; import com.amazonaws.regions.Region; import com.amazonaws.services.sqs.AmazonSQS; -import com.amazonaws.services.sqs.model.AddPermissionRequest; -import com.amazonaws.services.sqs.model.AddPermissionResult; -import com.amazonaws.services.sqs.model.BatchEntryIdsNotDistinctException; -import com.amazonaws.services.sqs.model.BatchRequestTooLongException; -import com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchRequest; -import com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchRequestEntry; -import com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchResult; -import com.amazonaws.services.sqs.model.ChangeMessageVisibilityRequest; -import com.amazonaws.services.sqs.model.ChangeMessageVisibilityResult; -import com.amazonaws.services.sqs.model.CreateQueueRequest; -import com.amazonaws.services.sqs.model.CreateQueueResult; -import com.amazonaws.services.sqs.model.DeleteMessageBatchRequest; -import com.amazonaws.services.sqs.model.DeleteMessageBatchRequestEntry; -import com.amazonaws.services.sqs.model.DeleteMessageBatchResult; -import com.amazonaws.services.sqs.model.DeleteMessageRequest; -import com.amazonaws.services.sqs.model.DeleteMessageResult; -import com.amazonaws.services.sqs.model.DeleteQueueRequest; -import com.amazonaws.services.sqs.model.DeleteQueueResult; -import com.amazonaws.services.sqs.model.EmptyBatchRequestException; -import com.amazonaws.services.sqs.model.GetQueueAttributesRequest; -import com.amazonaws.services.sqs.model.GetQueueAttributesResult; -import com.amazonaws.services.sqs.model.GetQueueUrlRequest; -import com.amazonaws.services.sqs.model.GetQueueUrlResult; -import com.amazonaws.services.sqs.model.InvalidAttributeNameException; -import com.amazonaws.services.sqs.model.InvalidBatchEntryIdException; -import com.amazonaws.services.sqs.model.InvalidIdFormatException; -import com.amazonaws.services.sqs.model.InvalidMessageContentsException; -import com.amazonaws.services.sqs.model.ListDeadLetterSourceQueuesRequest; -import com.amazonaws.services.sqs.model.ListDeadLetterSourceQueuesResult; -import com.amazonaws.services.sqs.model.ListQueueTagsRequest; -import com.amazonaws.services.sqs.model.ListQueueTagsResult; -import com.amazonaws.services.sqs.model.ListQueuesRequest; -import com.amazonaws.services.sqs.model.ListQueuesResult; -import com.amazonaws.services.sqs.model.MessageNotInflightException; -import com.amazonaws.services.sqs.model.OverLimitException; -import com.amazonaws.services.sqs.model.PurgeQueueInProgressException; -import com.amazonaws.services.sqs.model.PurgeQueueRequest; -import com.amazonaws.services.sqs.model.PurgeQueueResult; -import com.amazonaws.services.sqs.model.QueueDeletedRecentlyException; -import com.amazonaws.services.sqs.model.QueueDoesNotExistException; -import com.amazonaws.services.sqs.model.QueueNameExistsException; -import com.amazonaws.services.sqs.model.ReceiptHandleIsInvalidException; -import com.amazonaws.services.sqs.model.ReceiveMessageRequest; -import com.amazonaws.services.sqs.model.ReceiveMessageResult; -import com.amazonaws.services.sqs.model.RemovePermissionRequest; -import com.amazonaws.services.sqs.model.RemovePermissionResult; -import com.amazonaws.services.sqs.model.SendMessageBatchRequest; -import com.amazonaws.services.sqs.model.SendMessageBatchRequestEntry; -import com.amazonaws.services.sqs.model.SendMessageBatchResult; -import com.amazonaws.services.sqs.model.SendMessageRequest; -import com.amazonaws.services.sqs.model.SendMessageResult; -import com.amazonaws.services.sqs.model.SetQueueAttributesRequest; -import com.amazonaws.services.sqs.model.SetQueueAttributesResult; -import com.amazonaws.services.sqs.model.TagQueueRequest; -import com.amazonaws.services.sqs.model.TagQueueResult; -import com.amazonaws.services.sqs.model.TooManyEntriesInBatchRequestException; -import com.amazonaws.services.sqs.model.UntagQueueRequest; -import com.amazonaws.services.sqs.model.UntagQueueResult; +import com.amazonaws.services.sqs.model.*; +import java.lang.UnsupportedOperationException; import java.util.List; import java.util.Map; @@ -2051,4 +1995,21 @@ public void shutdown() { return amazonSqsToBeExtended.untagQueue(queueUrl, tagKeys); } + /** {@inheritDoc} */ + @Override + public StartMessageMoveTaskResult startMessageMoveTask(StartMessageMoveTaskRequest startMessageMoveTaskRequest) { + return amazonSqsToBeExtended.startMessageMoveTask(startMessageMoveTaskRequest); + } + + /** {@inheritDoc} */ + @Override + public ListMessageMoveTasksResult listMessageMoveTasks(ListMessageMoveTasksRequest listMessageMoveTasksRequest) { + return amazonSqsToBeExtended.listMessageMoveTasks(listMessageMoveTasksRequest); + } + + /** {@inheritDoc} */ + @Override + public CancelMessageMoveTaskResult cancelMessageMoveTask(CancelMessageMoveTaskRequest cancelMessageMoveTaskRequest) { + return amazonSqsToBeExtended.cancelMessageMoveTask(cancelMessageMoveTaskRequest); + } }