将 rabbitmq 消费者分离并重新附加到交换

Question

我有一个场景，我需要在特定事件上将 rabbitmq 消费者从交换器中分离出来，以便它停止使用队列中的消息，然后将同一个消费者重新连接到交换器并开始使用消息再次。我正在使用 Spring-RabbitMQ 1.6。

到目前为止，我已经在互联网上阅读了几页内容，例如http://www.programcreek.com/java-api-examples/index.php?api=org.springframework.amqp.rabbit.core.RabbitAdmin

和 http://docs.spring.io/spring-amqp/docs/1.6.0.RC1/reference/htmlsingle/#idle-containers 以及许多其他人，但不能完全理解如何让它发挥作用。

Answer 1

您可以简单地调用container.stop()来停止消费者； start() 将重新启动它。