Как запустить, остановить и повторно подключить контейнеры слушателя spring rabbitmq и их соединения?

У меня есть интернет-соединение, где выходной шлюз периодически меняется. Я получаю уведомление о событии или обратном вызове в свое весеннее приложение за несколько секунд до того, как это произойдет. Я хотел бы затем остановить своих потребителей и соединения кролика и через несколько секунд снова подключиться (когда мое сетевое соединение вернется).

Я использую основанный на аннотациях подход Spring AMQP, но я также мог бы перейти к другому виду реализации.

Я знаю, что spring-amqp делает переподключение для меня, но я хотел бы сделать это сам, чтобы иметь больше контроля над ним. Как я могу программно сделать полную остановку всех потребителей (RabbitListeners), а также чистое отключение от брокера rabbitmq и снова чистое соединение и запуск всех потребителей? Было бы хорошо, если бы потребители воссоздали. Если это невозможно, мне придется заново инициализировать некоторые атрибуты объекта.

Ответы на вопрос(1)

Ваш ответ на вопрос