How can I implement long polling an AWS SQS queue in my Quarkus reactive app?

[MihaiBogdanEugen]

Hi all,

I'm working at a Quarkus reactive application, using AWS SDK v2 (the async version). The requirements are quite simple: (1) listen to messages coming from a queue, (2) apply business logic, (3) save them to a datastore, (4) offer an HTTP api that serves them. I'm only talking about part (1), and the queue used is AWS SQS.

I am aware that AWS SQS does not offer any native reactive api, but how can I achieve this? I believe I need to long pool SQS on a worker thread, but I can't find any helpful examples...

Just for reference, the AWS SDK offers you the following:

• Retrieve any messages that are currently in the queue by calling the SqsAsyncClient receiveMessage method. This method takes a ReceiveMessageRequest that contains the queue URL. You can also specify the maximum number of messages to return. Messages are returned as a list of Message objects.

            ReceiveMessageRequest receiveMessageRequest = ReceiveMessageRequest.builder()
                .queueUrl(queueUrl)
                .maxNumberOfMessages(5)
                .build();
            List<Message> messages = sqsAsyncClient.receiveMessage(receiveMessageRequest).get().messages();

• After receiving a message and processing its contents, delete the message from the queue by sending the message’s receipt handle and queue URL to the SqsAsyncClient deleteMessage method.

                DeleteMessageRequest deleteMessageRequest = DeleteMessageRequest.builder()
                    .queueUrl(queueUrl)
                    .receiptHandle(message.receiptHandle())
                    .build();
                sqsAsyncClient.deleteMessage(deleteMessageRequest).get();