Skip to content

Commit 0557e3f

Browse files
committed
Handled review comments
1 parent 095e63b commit 0557e3f

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

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

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -60,11 +60,9 @@ public CompletableFuture<ReceiveMessageResponse> processRequest(ReceiveMessageRe
6060
return queueAttributesManager.getReceiveMessageTimeout(rq, config.messageMinWaitDuration()).thenCompose(waitTimeMs -> {
6161
CompletableFuture<ReceiveMessageResponse> receiveMessageFuture = new CompletableFuture<>();
6262
receiveQueueBuffer.receiveMessage(receiveMessageFuture, numMessages);
63-
executor.schedule(() -> {
64-
if (!receiveMessageFuture.isDone()) {
65-
receiveMessageFuture.complete(ReceiveMessageResponse.builder().build());
66-
}
67-
}, waitTimeMs.toMillis(), TimeUnit.MILLISECONDS);
63+
executor.schedule(() -> receiveMessageFuture.complete(ReceiveMessageResponse.builder().build()),
64+
waitTimeMs.toMillis(),
65+
TimeUnit.MILLISECONDS);
6866
return receiveMessageFuture;
6967

7068
});

0 commit comments

Comments
 (0)