Разрешить rabbitmq для обработки текущего запущенного сообщения перед выключением
Мое приложение - это микро-сервис весенней загрузки, слушающий очередь Rabbit MQ. Очередь получает сообщения из разных источников.
Требование заключается в том, что когда сервер приложений выходит из строя (это может произойти по многим причинам, может быть потому, что мы закрыли сайт или мы развернули обновленное программное обеспечение на нашем сервере приложений), мы бы хотели, чтобы очередь обрабатывала текущее сообщение На данный момент мы теряем сообщение о том, что очередь в данный момент обрабатывает. Как мне этого добиться?
1 ответ
По умолчанию shutdownTimeout
составляет 5000 мс; Вы можете увеличить это.
Вы не должны, однако, терять какие-либо сообщения, они должны быть поставлены в очередь (если вы не используете AcknowledgeMode.NONE
(что вообще плохая идея).