An example using rabbit mq synchronously.
Store sends a request, which is picked up by Query, who sends a modified request to Enrichment.
Enrichment responds back to Query, who returns the result back to Store.
Multiple stores are supported - you can see messages only going to the store as the routingKey forwards it to the correct store. To set this up, create a copy of the run configuration for the store and override the environment variables:
storeNumber- to a different valueserver.port- to a different port
Query and Enrichment do not have spring-starter-web and do not run on a port. They only listen to rabbit mq events.
Also, spring-cloud-starter-sleuth has been added to see trace/span ids per request.
- Uses Lombok - be sure to enable annotation processing
- Uses RabbitMQ - install and run via brew or docker
Query has an example of an integration test, which uses a mock RabbitMQ: https://github.com/fridujo/rabbitmq-mock