liveBook · Manning

Quarkus-messaging-rabbitmq

As explained in Quarkus in Action

quarkus-messaging-rabbitmq is a Quarkus extension that integrates SmallRye Reactive Messaging with RabbitMQ.

quarkus-messaging-rabbitmq integrates SmallRye Reactive Messaging with RabbitMQ, moving channels from in-memory delivery to a broker without changing the reactive messaging model. section 9.7

Use the extension to connect application channels to RabbitMQ:

  • Map an outgoing invoices channel to a RabbitMQ exchange and a consuming channel to a queue. section 9.7

Invoice consumption

A BillingService method annotated with @Incoming("invoices-rabbitmq") receives a JsonObject, maps it to Invoice, and processes it. In Dev mode, Quarkus starts a RabbitMQ-compatible broker automatically.

How Quarkus in Action covers it

How deep it goes
Explains extension installation, channel mapping, queue configuration, consumer changes, and Dev Service startup.
Examples
Uses invoice emission, renamed incoming channels, RabbitMQ queue properties, and a BillingService consumer.
What it assumes
Assumes an existing reactive messaging setup with invoice production and consumption channels.
What you can do after
Apply the extension to route reactive messaging invoices through RabbitMQ and consume them from a configured queue.
How it connects
Connects SmallRye Reactive Messaging, RabbitMQ, AMQP 1.0, in-memory channels, exchanges, queues, and Dev Services.

Related concepts

This explainer was generated by Manning's knowledge graph from the text of Quarkus in Action. The section links point to the parts of the book it draws on.