spring-amqp - 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());

使用此配置，如何配置监听器1从队列1检索消息和监听器2从队列2检索消息？

Answer 1

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

一个容器只能有一个监听器； XML 只是一种连接具有公共(public)属性的多个容器的便捷方法(来自 <rabbit:listener-container/> 元素)。