This is a quick PoC demonstrating how to implement a microservices architecture in which business logic is driven by a BPM engine. (Micro)services are created in a Spring Boot app (bundled together for convenience) and communicate with AMQP.
RabbitMQ has been used as the AMQP broker and Camunda BPM as the workflow engine.
The different modules of this PoC implement the following architecture:
The following simple workflow is being used:
An input is given to the workflow via the REST API of the PoC app, which is then passed through different services, first capitalising it and then add a "Hello" message. For example, "John" becomes "Hello JOHN".
A third service is also available to reverse the payload which can be used to demonstrate how the business logic of the PoC can be changed without affecting the services deployed.
As microservices communication takes place using an AMQP broker, you need to have a RabbitMQ instance available. You can quickly fire up a Docker container with RabbitMQ with:
docker run --rm --hostname rabbitmq --name rabbitmq -p 5672:5672 rabbitmq
All PoC apps are Spring Boot applications, so to run them you can execute the following steps in the root folder of each application:
mvn spring-boot:runcurl "http://localhost:8081/api/hello?name=john"Using the unique id provided as a result to the above call:
curl "http://localhost:8081/api/query?id=XYZ"