Skip to content

RabbitMQ Connector

The RabbitMQ Connector adds support for RabbitMQ to Reactive Messaging, based on the AMQP 0-9-1 Protocol Specification.

Advanced Message Queuing Protocol 0-9-1 (AMQP 0-9-1) is an open standard for passing business messages between applications or organizations.

With this connector, your application can:

  • receive messages from a RabbitMQ queue
  • send messages to a RabbitMQ exchange

The RabbitMQ connector is based on the Vert.x RabbitMQ Client.

Important

The AMQP connector supports the AMQP 1.0 protocol, which is very different from AMQP 0-9-1. You can use the AMQP connector with RabbitMQ provided that the latter has the AMQP 1.0 Plugin installed, albeit with reduced functionality.

Using the RabbitMQ connector

To use the RabbitMQ Connector, add the following dependency to your project:

1
2
3
4
5
<dependency>
  <groupId>io.smallrye.reactive</groupId>
  <artifactId>smallrye-reactive-messaging-rabbitmq</artifactId>
  <version>4.18.1</version>
</dependency>

The connector name is: smallrye-rabbitmq.

So, to indicate that a channel is managed by this connector you need: 

1
2
3
4
5
# Inbound
mp.messaging.incoming.[channel-name].connector=smallrye-rabbitmq

# Outbound
mp.messaging.outgoing.[channel-name].connector=smallrye-rabbitmq