对于最新的稳定版本,请使用 Spring AMQP 3.2.0! |
容器和 Broker-Named 队列
虽然最好使用AnonymousQueue
实例作为自动删除队列,从版本 2.1 开始,您可以将名为 Queues 的代理与侦听器容器一起使用。
以下示例显示了如何执行此作:
@Bean
public Queue queue() {
return new Queue("", false, true, true);
}
@Bean
public SimpleMessageListenerContainer container() {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(cf());
container.setQueues(queue());
container.setMessageListener(m -> {
...
});
container.setMissingQueuesFatal(false);
return container;
}
请注意空的String
对于名称。
当RabbitAdmin
声明队列,它会更新Queue.actualName
属性替换为 broker 返回的名称。
您必须使用setQueues()
当您配置容器以使其正常工作时,以便容器可以在运行时访问声明的名称。
仅仅设置名称是不够的。
当容器运行时,您无法将代理命名的队列添加到容器中。 |
重置连接并建立新连接时,新队列将获得新名称。
由于容器重启和队列被重新声明之间存在争用条件,因此将容器的missingQueuesFatal property 设置为false ,因为容器最初可能会尝试重新连接到旧队列。 |