Using MicroProfile Reactive Messaging to build a reactive application
MicroProfile Reactive Messaging 2.0 (https://download.eclipse.org/microprofile/microprofile-reactive-messaging-2.0/) provides a mechanism for building event-driven cloud-native applications. It enables decoupling between the services via messaging. MicroProfile Reactive Messaging provides the @Outgoing
annotation for publishing messages and @Incoming
for consuming messages. The following figure illustrates how messages travel from the publisher (Method A) to the consumer (Method B). The message can be sent to a messaging store, such as Apache Kafka, MQ, and so on, and will then be delivered to a consumer such as Method B:
In Reactive Messaging, CDI beans are used to produce, process, and consume messages. These messages can be sent and received via remote brokers or various message transport layers such as Apache Kafka, MQ, and so on. Let's discuss...