How to Write and Test a Reactive Reader for AWS SQS Using akka, alpakka and Localstack

AWS SQS stands for Simple Queue Service. This example explains how to

• connect to SQS via alpakka,
• process the messages reactively in via akka streams,
• test the pipeline using Localstack and Mockito,
• all in scala, of course.

For a complete introduction, see the blog post!

Running the Code

Prerequisites

You need docker and the aws-cli installed.

Setup

Run the start_localstack.sh script first:

$ ./run_localstack.sh

Compile & Run

Start sbt and run!

$ sbt
sbt:reactive-sqs> run

Testing

Tests need the localstack as well. Then start sbt and test:

$ sbt
sbt:reactive-sqs> test