SimpleMessageListenerContainer 为每个侦听器单独队列（java 配置）

Question

我正在尝试将以下 xml 配置转换为 java 配置。此配置提到 listener1 将从 queue1 和 listener2 从 queue2

检索消息

<rabbit:listener-container connection-factory="connectionFactory">
    <rabbit:listener ref="listener1" queues="queue1" />
    <rabbit:listener ref="listener2" queues="queue2" />
</rabbit:listener-container>

使用java配置，我做了以下操作：

SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory());
container.setQueues(queue1(), queue2());
container.setMessageListener(messageListenerAdapter1());
container.setMessageListener(messageListenerAdapter2());

使用此配置，如何配置 listener1 从 queue1 检索消息，以及 listener2 从 queue2 检索消息？

Answer 1

XML 配置解析器为每个 <rabbit:listener /> 元素创建一个新的 SimpleMessageListenerContainer。

一个容器只能有一个监听器； XML 只是连接具有共同属性的多个容器的便捷方式（来自 <rabbit:listener-container/> 元素）。

SimpleMessageListenerContainer 为每个侦听器单独队列（java 配置）

SimpleMessageListenerContainer separate queue for each listener (java configuration)

spring-amqp