可声明对象和MultiRabbit

Question

我使用spring-multirabbit库:

rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
multirabbitmq:
enabled: true
connections:
my-rabbitmq:
host: localhost
port: 5677
username: guest
password: guest

如何确保"可声明性"只作用于一个特定的兔子连接，而不作用于所有声明的兔子连接?

@Bean
public Declarables queues(MessagingProperties props) {
Declaradles declarables = /* build declarables...? */
return declarables;
}

Answer 1

Ok…我知道怎么解决它了

在可声明对象上使用方法:'setAdminsThatShouldDeclare'指定admin:

@Bean
public Declarables queues(MessagingProperties messagingProperties) {
return new Declarables(messagingProperties.getBindings().stream().map(b ->
{
Declarable queue = QueueBuilder.nonDurable(b.getQueue()).build();
queue.setAdminsThatShouldDeclare("my-rabbitmq-admin");
return queue;
}).collect(Collectors.toList()));
}