Skip to content

Instantly share code, notes, and snippets.

@bijukunjummen

bijukunjummen/FetchingRecordsAsync.kt

Created May 3, 2020 00:40
Show Gist options
  • Save bijukunjummen/fa5318637ca59f4d076d10d64939e817 to your computer and use it in GitHub Desktop.
Save bijukunjummen/fa5318637ca59f4d076d10d64939e817 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
FetchingRecordsAsync.kt
val receiveMessageRequest: ReceiveMessageRequest = ReceiveMessageRequest.builder()
    .queueUrl(queueUrl)
    .maxNumberOfMessages(5)
    .waitTimeSeconds(10)
    .build()
 
val messages: CompletableFuture<List<Message>> = sqsAsyncClient
    .receiveMessage(receiveMessageRequest)
    .thenApply { result -> result.messages() }
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment