Class DefaultSqsAsyncBatchManager

java.lang.Object

software.amazon.awssdk.services.sqs.internal.batchmanager.DefaultSqsAsyncBatchManager

All Implemented Interfaces:

AutoCloseable, SqsAsyncBatchManager, SdkAutoCloseable

public final class DefaultSqsAsyncBatchManager
extends Object
implements SqsAsyncBatchManager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	DefaultSqsAsyncBatchManager.DefaultBuilder

Nested classes/interfaces inherited from interface software.amazon.awssdk.services.sqs.batchmanager.SqsAsyncBatchManager

SqsAsyncBatchManager.Builder

Method Summary

Modifier and Type	Method	Description
static SqsAsyncBatchManager.Builder	builder()
CompletableFuture<ChangeMessageVisibilityResponse>	changeMessageVisibility(ChangeMessageVisibilityRequest request)	Buffers and batches ChangeMessageVisibilityRequests, sending them as a ChangeMessageVisibilityBatchRequest.
void	close()
CompletableFuture<DeleteMessageResponse>	deleteMessage(DeleteMessageRequest request)	Buffers and batches DeleteMessageRequests, sending them as a DeleteMessageBatchRequest.
CompletableFuture<ReceiveMessageResponse>	receiveMessage(ReceiveMessageRequest request)	Buffers and retrieves messages with ReceiveMessageRequest, with a maximum of 10 messages per request.
CompletableFuture<SendMessageResponse>	sendMessage(SendMessageRequest request)	Buffers and batches SendMessageRequests, sending them as a SendMessageBatchRequest.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface software.amazon.awssdk.services.sqs.batchmanager.SqsAsyncBatchManager

changeMessageVisibility, deleteMessage, receiveMessage, sendMessage

Method Details

sendMessage

public CompletableFuture<SendMessageResponse> sendMessage(SendMessageRequest request)

Description copied from interface: SqsAsyncBatchManager

Buffers and batches SendMessageRequests, sending them as a SendMessageBatchRequest. Requests are grouped by queue URL and override configuration, and sent when the batch size or timeout is reached.

Specified by:

sendMessage in interface SqsAsyncBatchManager

Parameters:

request - The SendMessageRequest to be buffered.

Returns:

CompletableFuture of the corresponding SendMessageResponse.

deleteMessage

public CompletableFuture<DeleteMessageResponse> deleteMessage(DeleteMessageRequest request)

Description copied from interface: SqsAsyncBatchManager

Buffers and batches DeleteMessageRequests, sending them as a DeleteMessageBatchRequest. Requests are grouped by queue URL and override configuration, and sent when the batch size or timeout is reached.

Specified by:

deleteMessage in interface SqsAsyncBatchManager

Parameters:

request - The DeleteMessageRequest to be buffered.

Returns:

CompletableFuture of the corresponding DeleteMessageResponse.

changeMessageVisibility

public CompletableFuture<ChangeMessageVisibilityResponse> changeMessageVisibility(ChangeMessageVisibilityRequest request)

Description copied from interface: SqsAsyncBatchManager

Buffers and batches ChangeMessageVisibilityRequests, sending them as a ChangeMessageVisibilityBatchRequest. Requests are grouped by queue URL and override configuration, and sent when the batch size or timeout is reached.

Specified by:

changeMessageVisibility in interface SqsAsyncBatchManager

Parameters:

request - The ChangeMessageVisibilityRequest to be buffered.

Returns:

CompletableFuture of the corresponding ChangeMessageVisibilityResponse.

receiveMessage

public CompletableFuture<ReceiveMessageResponse> receiveMessage(ReceiveMessageRequest request)

Description copied from interface: SqsAsyncBatchManager

Buffers and retrieves messages with ReceiveMessageRequest, with a maximum of 10 messages per request. Returns an empty message if no messages are available in SQS.

Specified by:

receiveMessage in interface SqsAsyncBatchManager

Parameters:

request - The ReceiveMessageRequest.

Returns:

CompletableFuture of the corresponding ReceiveMessageResponse.

builder

public static SqsAsyncBatchManager.Builder builder()

close

public void close()

Description copied from interface: SdkAutoCloseable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SdkAutoCloseable