Micronaut:存在多个连接时如何在 ChannelPoolListener 中创建队列
Micronaut: How to create queues in ChannelPoolListener when multiple connections exist
具有 io.micronaut.rabbitmq:micronaut-rabbitmq
依赖项的 Micronaut 3.0.2。
我想使用多个连接,然后使用建议的 ChannelPoolListener
基于 io.micronaut.rabbitmq.connect.ChannelInitializer
创建 queues/exchanges 使用名为 configbus
.[=15 的特定连接=]
micronaut:
application:
name: micronautRabbitmq
rabbitmq:
servers:
configbus:
uri: amqp://localhost:5672
username: micronautRabbitmq
password: micronautRabbitmq
eventbus:
uri: amqp://localhost:5671
username: micronautRabbitmq
password: micronautRabbitmq
我该怎么做?
您可能只是缺少主机和端口密钥。
在此处查看连接部分:
https://micronaut-projects.github.io/micronaut-rabbitmq/latest/guide/#config
从 micronaut-rabbitmq:3.1.0
开始,ChannelInitializer 获取连接的名称。因此,无论何时为所需的连接调用初始化方法,您都可以使用通道创建队列、交换、绑定等。
https://micronaut-projects.github.io/micronaut-rabbitmq/latest/guide/#initialization
具有 io.micronaut.rabbitmq:micronaut-rabbitmq
依赖项的 Micronaut 3.0.2。
我想使用多个连接,然后使用建议的 ChannelPoolListener
基于 io.micronaut.rabbitmq.connect.ChannelInitializer
创建 queues/exchanges 使用名为 configbus
.[=15 的特定连接=]
micronaut:
application:
name: micronautRabbitmq
rabbitmq:
servers:
configbus:
uri: amqp://localhost:5672
username: micronautRabbitmq
password: micronautRabbitmq
eventbus:
uri: amqp://localhost:5671
username: micronautRabbitmq
password: micronautRabbitmq
我该怎么做?
您可能只是缺少主机和端口密钥。
在此处查看连接部分: https://micronaut-projects.github.io/micronaut-rabbitmq/latest/guide/#config
从 micronaut-rabbitmq:3.1.0
开始,ChannelInitializer 获取连接的名称。因此,无论何时为所需的连接调用初始化方法,您都可以使用通道创建队列、交换、绑定等。
https://micronaut-projects.github.io/micronaut-rabbitmq/latest/guide/#initialization