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!

You need docker and the aws-cli installed.

Run the start_localstack.sh script first:

$ ./run_localstack.sh

Start sbt and run!

$ sbt
sbt:reactive-sqs> run

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

$ sbt
sbt:reactive-sqs> test