Skip to content

thiyagu06/reactive-sqs-consumer

Repository files navigation

reactive-sqs-consumer

Kotlin version badge License codebeat badge CircleCI codecov Maven Central

Introduction

This reactive sqs consumer built with aim to reduce the boilerplate code to launch the sqs consumer and allow the developers to focus on processing the message for implement the business logic. This has been built from the scratch with a goal making it easy to customizable allowing each component of the library is easy to interchangeable if desired. This also, allows us define custom configuration such as amount of thread to fetch messages and amount of threads to process the messages etc.

The distinguished feature of reactive sqs consumer are

Design

This library is divided into four sub components each with its own responsibilities. The below diagram shows the simple flow of sqs message lifecycle flowing throw each components.

Design Diagram

usage

See ExampleUsage.kt for how to use this library.