java - 如何在具有多个队列的 RabbitMQ 中调用特定队列的特定方法？

Question

我在rabbitMQ中有2个队列，queueA和queueB

当 queueA和/或 queueB填满数据(通过convertAndSend()方法)，会自动调用MessageListener.onMessage()方法(CMIIW)。

所以，我的问题是，我该如何调用 methodA() ，当 queueA已满，请调用methodB()当queueB已满。

不同队列有不同方法

Answer 1

参见the documentation .

您可以使用两个监听器容器(每个队列一个)，并使用配置为为每个队列调用适当方法的 MessageListenerAdapter(请参阅 setDefaultListenerMethod())。

您可以使用监听两个队列的单个监听器容器、子类 MessageListenerAdapter 并实现 getListenerMethodName() 来根据消息确定要调用哪个方法。从 Spring AMQP 版本 1.4.2 开始，接收消息的队列在

中可用

originalMessage.getMessageProperties().get(AmqpHeaders.CONSUMER_QUEUE)