如何停止使用@RabbitListener 消费消息

Question

当我使用 MessageListenerAdapter 处理消息时，我可以调用 SimpleMessageListenerContainer.stop() 来停止从队列中消费。但是我改用@RabbitListener 监听后，就找不到这样的方法了。我试过 CachingConnectionFactory.stop() 但不起作用。有人可以帮忙吗？非常感谢。

Answer 1

1. 给@RabbitListener 一个id。
2. 通过自动装配等获取对listener endpoint registry bean 的引用。
3. 在注册表上调用stop() 将停止所有容器。
4. 调用getListenerContainer(id).stop() 停止单个容器。