Получать сообщения от Sqs, используя реактивное программирование

Question

Я новичок в разработке программного обеспечения и хочу получать сообщения от aws sqs неблокирующим способом с помощью реактивного программирования. Как это сделать

Answer 1

В Java AWS SDK 2 встроены асинхронные клиенты - SqsAsyncClient - это то, что вам нужно в этом случае.

Вы можете использовать CompleteableFuture этот метод возвращает как есть - если вы хотите использовать проектный реактор специально (как отмечено в вопросе), то вы можете просто обернуть вышеупомянутое в Mono.fromFuture(), чтобы получить Mono<ReceiveMessageResponse>.