交換機にrabbitmqコンシューマを切り離して再接続する

私は、特定のイベントで交換機からrabbitmqコンシューマを切り離して、キュー内のメッセージの消費を停止してから同じコンシューマを交換し、メッセージを再び消費し始める。私はSpring-RabbitMQ 1.6を使用しています。交換機にrabbitmqコンシューマを切り離して再接続する

これまでのところ、私はインターネット上のいくつかのページを読んだ。 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などがありますが、それを正しく動作させる方法を正確に理解できませんでした。

出典

2016-08-27 Lalit Mehra

container.stop()に電話してコンシューマを停止することができます。 start()が再起動します。

出典

2016-08-27 13:12:20

ok。コンテナにアクセスする方法は？私は "RabbitListenerEndpointRegistry"の処分でこのクラスが必要になると思いますが、アクセスする方法を見つけることができませんでした。私はRabbitAdminとRabbitTemplateのBeanを私にアクセスできます。 –

通常のSpringテクニック（コンストラクタのargやプロパティ、 '@ Autowire'、' context.getBean（） 'など）を使ってレジストリへの参照を取得し、それを停止/開始することができます@ RabbitListener "id"を使ってレジストリから個々のコンテナを取得し、それらを停止/開始することができます。 [the documentation]（http://docs.spring.io/spring-amqp//reference/html/_reference.html#_container_management）を参照してください。 –

ありがとうございました。私はrabbitmqコンテキストxmlにいくつかの変更を行い、Collection beanを介してすべてのリスナーの参照を取得しました。 –

交換機にrabbitmqコンシューマを切り離して再接続する

答えて

関連する問題