Spring AMQP ListenerContainer управление жизненным циклом

Question

Мы используем Spring AMQP для подключения к RabbitMQ в нашем веб-приложении Spring.

Когда мы объявляем наши контейнеры-слушатели как бобы (используя rabbit:listener-container) в контексте приложения, их жизненный цикл управляется Spring.

Если мы объявляем слушатель-контейнер в компоненте внутри метода @PostConstruct, или мы создаем боб с классом org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer в качестве прототипа области действия фасоли, мы тогда должны управлять жизненным циклом, т.е. запуска и остановки слушателя-контейнер сам.

Мой вопрос, если мы объявляем новые очереди, привязок и слушателем-контейнеры внутри метода @PostConstruct, просто вызывая listener.stop/shutdown/destroy метод внутри соответствующего @PreDestroy метода будет достаточно для постепенного выключения? Или что мне нужно делать?

Примечание: Я предполагаю, что мне не нужно ничего делать для новых очередей и привязок, созданных в @PostContruct, но я был бы очень рад, если вы также подтвердите это для меня.

Answer 1

Я бы не рекомендовал запускать контейнер-слушатель или объявлять очереди/привязки в методе @PostConstruct; в то время контекст только полупелен. Он может работать, но не рекомендуется делать такие вещи, пока контекст инициализируется.

Лучше реализовать SmartLifecycle и начать/остановить их в методах start()/stop().

Тогда жизненные циклы контейнера будут косвенно управляться весенним контекстом.

Вы также можете точно контролировать, когда ваш бит запущен/остановлен, поставив его в фазе.