Quarkus - SmallRye Reactive Messaging - RabbitMQ: Send message to default exchange

user_19373322 0
Viewed 184

Using the remote procedure call pattern, I need to send an answer to a reply-queue, i.e. I need to send the message to the default exchange with the name of the queue as the routing key.

I am using the SmallRye Reactive Messing RabbitMQ plugin on Quarkus. All channels are defined statically in the configuration files (which is ok), however, due to the way the configuration mechanism works (microprofile config), I cannot use the empty string as a configuration value, which is the name of the default exchange.

It does not help to omit the name of the exchange, as by default the channel name is used.

Is there a way to send a message to the default exchange using the SmallRye RabbitMQ plugin?

Edit: I have no control over the RabbitMQ server.

smallrye-reactive-messaging quarkus rabbitmq
1 Answers

You should be able to send messages to the default direct RabbitMQ exchange by setting below attributes:

  • exchange.name (set to empty string)
  • exchange.type (set to direct)

Assuming your Reactive Messaging channel is named pets-out, here down a configuration sample:

mp.messaging.outgoing.pets-out.connector=smallrye-rabbitmq
mp.messaging.outgoing.pets-out.exchange.name=
mp.messaging.outgoing.pets-out.exchange.declare=false
mp.messaging.outgoing.pets-out.exchange.type=direct
mp.messaging.outgoing.pets-out.default-routing-key=pets

EDIT

After digging into smallrye-reactive-messaging implementation, I figured out that an empty exchange name will cause a fallback to the channel name as the exchange name.

Hence, there should be no way to send direct messages to the default RabbitMQ exchange.

The alternative solution, neglecting the out-of-the-box offered default exchange would be to

  1. Create a direct exchange without any bound queues and have the Outgoing message handler using a dedicated channel config bound to it:

     mp.messaging.outgoing.pets-out.connector=smallrye-rabbitmq
 mp.messaging.outgoing.pets-out.exchange.name=my-direct
 mp.messaging.outgoing.pets-out.exchange.declare=true
 mp.messaging.outgoing.pets-out.exchange.type=direct
 mp.messaging.outgoing.pets-out.default-routing-key=pets

  2. Create an alternate exchange configuration for the my-direct exchange routing messages to the default one. This can be operated on the RabbitMQ broker directly using rabbitmqctl:

     rabbitmqctl set_policy AE "^my-direct$" '{"alternate-exchange":""}' --apply-to exchanges
user_21065160
Related