Skip to content

Commit f0959cb

Browse files
Add SQS ReDrive APIs in the updated model
1 parent 9f7a626 commit f0959cb

File tree

1 file changed

+19
-58
lines changed

1 file changed

+19
-58
lines changed

src/main/java/com/amazon/sqs/javamessaging/AmazonSQSExtendedClientBase.java

Lines changed: 19 additions & 58 deletions
Original file line numberDiff line numberDiff line change
@@ -23,65 +23,9 @@
2323
import com.amazonaws.auth.AWSCredentialsProvider;
2424
import com.amazonaws.regions.Region;
2525
import com.amazonaws.services.sqs.AmazonSQS;
26-
import com.amazonaws.services.sqs.model.AddPermissionRequest;
27-
import com.amazonaws.services.sqs.model.AddPermissionResult;
28-
import com.amazonaws.services.sqs.model.BatchEntryIdsNotDistinctException;
29-
import com.amazonaws.services.sqs.model.BatchRequestTooLongException;
30-
import com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchRequest;
31-
import com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchRequestEntry;
32-
import com.amazonaws.services.sqs.model.ChangeMessageVisibilityBatchResult;
33-
import com.amazonaws.services.sqs.model.ChangeMessageVisibilityRequest;
34-
import com.amazonaws.services.sqs.model.ChangeMessageVisibilityResult;
35-
import com.amazonaws.services.sqs.model.CreateQueueRequest;
36-
import com.amazonaws.services.sqs.model.CreateQueueResult;
37-
import com.amazonaws.services.sqs.model.DeleteMessageBatchRequest;
38-
import com.amazonaws.services.sqs.model.DeleteMessageBatchRequestEntry;
39-
import com.amazonaws.services.sqs.model.DeleteMessageBatchResult;
40-
import com.amazonaws.services.sqs.model.DeleteMessageRequest;
41-
import com.amazonaws.services.sqs.model.DeleteMessageResult;
42-
import com.amazonaws.services.sqs.model.DeleteQueueRequest;
43-
import com.amazonaws.services.sqs.model.DeleteQueueResult;
44-
import com.amazonaws.services.sqs.model.EmptyBatchRequestException;
45-
import com.amazonaws.services.sqs.model.GetQueueAttributesRequest;
46-
import com.amazonaws.services.sqs.model.GetQueueAttributesResult;
47-
import com.amazonaws.services.sqs.model.GetQueueUrlRequest;
48-
import com.amazonaws.services.sqs.model.GetQueueUrlResult;
49-
import com.amazonaws.services.sqs.model.InvalidAttributeNameException;
50-
import com.amazonaws.services.sqs.model.InvalidBatchEntryIdException;
51-
import com.amazonaws.services.sqs.model.InvalidIdFormatException;
52-
import com.amazonaws.services.sqs.model.InvalidMessageContentsException;
53-
import com.amazonaws.services.sqs.model.ListDeadLetterSourceQueuesRequest;
54-
import com.amazonaws.services.sqs.model.ListDeadLetterSourceQueuesResult;
55-
import com.amazonaws.services.sqs.model.ListQueueTagsRequest;
56-
import com.amazonaws.services.sqs.model.ListQueueTagsResult;
57-
import com.amazonaws.services.sqs.model.ListQueuesRequest;
58-
import com.amazonaws.services.sqs.model.ListQueuesResult;
59-
import com.amazonaws.services.sqs.model.MessageNotInflightException;
60-
import com.amazonaws.services.sqs.model.OverLimitException;
61-
import com.amazonaws.services.sqs.model.PurgeQueueInProgressException;
62-
import com.amazonaws.services.sqs.model.PurgeQueueRequest;
63-
import com.amazonaws.services.sqs.model.PurgeQueueResult;
64-
import com.amazonaws.services.sqs.model.QueueDeletedRecentlyException;
65-
import com.amazonaws.services.sqs.model.QueueDoesNotExistException;
66-
import com.amazonaws.services.sqs.model.QueueNameExistsException;
67-
import com.amazonaws.services.sqs.model.ReceiptHandleIsInvalidException;
68-
import com.amazonaws.services.sqs.model.ReceiveMessageRequest;
69-
import com.amazonaws.services.sqs.model.ReceiveMessageResult;
70-
import com.amazonaws.services.sqs.model.RemovePermissionRequest;
71-
import com.amazonaws.services.sqs.model.RemovePermissionResult;
72-
import com.amazonaws.services.sqs.model.SendMessageBatchRequest;
73-
import com.amazonaws.services.sqs.model.SendMessageBatchRequestEntry;
74-
import com.amazonaws.services.sqs.model.SendMessageBatchResult;
75-
import com.amazonaws.services.sqs.model.SendMessageRequest;
76-
import com.amazonaws.services.sqs.model.SendMessageResult;
77-
import com.amazonaws.services.sqs.model.SetQueueAttributesRequest;
78-
import com.amazonaws.services.sqs.model.SetQueueAttributesResult;
79-
import com.amazonaws.services.sqs.model.TagQueueRequest;
80-
import com.amazonaws.services.sqs.model.TagQueueResult;
81-
import com.amazonaws.services.sqs.model.TooManyEntriesInBatchRequestException;
82-
import com.amazonaws.services.sqs.model.UntagQueueRequest;
83-
import com.amazonaws.services.sqs.model.UntagQueueResult;
26+
import com.amazonaws.services.sqs.model.*;
8427

28+
import java.lang.UnsupportedOperationException;
8529
import java.util.List;
8630
import java.util.Map;
8731

@@ -2051,4 +1995,21 @@ public void shutdown() {
20511995
return amazonSqsToBeExtended.untagQueue(queueUrl, tagKeys);
20521996
}
20531997

1998+
/** {@inheritDoc} */
1999+
@Override
2000+
public StartMessageMoveTaskResult startMessageMoveTask(StartMessageMoveTaskRequest startMessageMoveTaskRequest) {
2001+
return amazonSqsToBeExtended.startMessageMoveTask(startMessageMoveTaskRequest);
2002+
}
2003+
2004+
/** {@inheritDoc} */
2005+
@Override
2006+
public ListMessageMoveTasksResult listMessageMoveTasks(ListMessageMoveTasksRequest listMessageMoveTasksRequest) {
2007+
return amazonSqsToBeExtended.listMessageMoveTasks(listMessageMoveTasksRequest);
2008+
}
2009+
2010+
/** {@inheritDoc} */
2011+
@Override
2012+
public CancelMessageMoveTaskResult cancelMessageMoveTask(CancelMessageMoveTaskRequest cancelMessageMoveTaskRequest) {
2013+
return amazonSqsToBeExtended.cancelMessageMoveTask(cancelMessageMoveTaskRequest);
2014+
}
20542015
}

0 commit comments

Comments
 (0)