An example illustrating consuming AMQP messages and inserting a corresponding row into a Postgresql database
- make sure you have docker-compose installed on your machine
- run
docker-compose up -dto run all containers in detached mode - Start the
scala-event-streamingapp - Using the rabbitmq console found at localhost:15627, publish a message to the queue named
amqp-conn-it-test-simple-queue-example- an example message is
{ "name": "Samus Aran", "email": "[email protected]" }