Hands-On Cloud-Native Applications with Java and Quarkus

Adding an EventBus layer to Quarkus applications

To include a distributed peer-to-peer messaging pattern in our application, we will need to inject the EventBus instance into a CDI bean, which will act as a receiver:

@Inject EventBus bus;

In our case, we will add the EventBus to the CustomerEndpoint class.

Please note that there is only one single instance of the Event Bus per Vert.x instance.

Now, in the same class, let's create a new endpoint method, which will be in charge of dispatching messages:

@GET@Path("/call")@Produces("text/plain")public CompletionStage<String> call(@QueryParam("id") Integer customerId) {    return bus.<String>send("callcustomer",     customerRepository.findCustomerById(customerId))            .thenApply(Message::body) .exceptionally(Throwable::getMessage) ...