Micronaut: How to create queues in ChannelPoolListener when multiple connections exist

Question

Micronaut 3.0.2 with io.micronaut.rabbitmq:micronaut-rabbitmq dependency.

I would like to use multiple connections and then use the proposed ChannelPoolListener based on io.micronaut.rabbitmq.connect.ChannelInitializer to create queues/exchanges using a specific connection named configbus.

micronaut:
  application:
    name: micronautRabbitmq
rabbitmq:
  servers:
    configbus:
      uri: amqp://localhost:5672
      username: micronautRabbitmq
      password: micronautRabbitmq
    eventbus:
      uri: amqp://localhost:5671
      username: micronautRabbitmq
      password: micronautRabbitmq

How do I do this?

score 0 · Answer 1 · answered Oct 12 '21 at 19:25

0

You might be just missing the host and port keys there.

See the connections section here: https://micronaut-projects.github.io/micronaut-rabbitmq/latest/guide/#config

answered Oct 12 '21 at 19:25

Nirav Assar

11
3

See the `uri` attribute. It combines host and port. – abedurftig Oct 12 '21 at 19:50

score 0 · Accepted Answer · answered Oct 12 '21 at 19:53

As of micronaut-rabbitmq:3.1.0 the ChannelInitializer gets the name of the connection. So, whenever the initialize method is called for the desired connection, you can use the channel to create queues, exchanges, bindings, etc.

https://micronaut-projects.github.io/micronaut-rabbitmq/latest/guide/#initialization

Micronaut: How to create queues in ChannelPoolListener when multiple connections exist

2 Answers2