Class ReceiveBatchManager

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, SdkAutoCloseable

@SdkInternalApi
public class ReceiveBatchManager
extends Object
implements SdkAutoCloseable

Constructor Summary

Constructors

Constructor	Description
ReceiveBatchManager(SqsAsyncClient sqsClient, ScheduledExecutorService executor, ResponseBatchConfiguration config, String queueUrl)

Method Summary

Modifier and Type	Method	Description
void	close()
CompletableFuture<ReceiveMessageResponse>	processRequest(ReceiveMessageRequest rq)

Methods inherited from class java.lang.Object

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

Constructor Details

ReceiveBatchManager

public ReceiveBatchManager(SqsAsyncClient sqsClient,
 ScheduledExecutorService executor,
 ResponseBatchConfiguration config,
 String queueUrl)

Method Details

processRequest

public CompletableFuture<ReceiveMessageResponse> processRequest(ReceiveMessageRequest rq)

close

public void close()

Description copied from interface: SdkAutoCloseable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SdkAutoCloseable