我有一个场景,我需要在特定事件上从交换机中分离一个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以及其他许多人但是不能完全理解如何使其发挥作用。
你可以简单地打电话给container.stop()
来阻止消费者; start()
将重启它。