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

Question

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

Answer 1

1. 为@RabbitListener提供一个id。
2. 获取 listener endpoint registry bean 的引用通过 Autowiring 等。
3. 在注册表上调用 stop() 将停止所有容器。
4. 调用 getListenerContainer(id).stop() 来停止单个容器。