Мы используем библиотеку Spring AMQP для приема сообщений из очередей в RabbitMQ. Наш издатель создает переменное количество сообщений по известному расписанию, поэтому мы думаем о том, чтобы запускать потребителей по расписанию и останавливаться, когда очередь пуста.
Мне интересно, как изящно закрыть канал и соединение, когда длина очереди достигает нуля?
Предстоящий выпуск 1.6 (кандидат на выпуск был выпущен на прошлой неделе, общедоступная версия должна состояться в конце следующей недели) имеет новая функция для генерации событий, когда контейнер прослушивателя простаивает.
Вы можете остановить контейнер при получении такого события. Вы не должны не останавливать контейнер в потоке, в котором вызывается прослушиватель событий — вместо этого передать событие в новый поток. Если вы попытаетесь остановить контейнер в том же потоке, это вызовет задержку, потому что контейнер ожидает освобождения потока.
receiveTimeout (по умолчанию 1 секунда) и проверяет время с момента получения последнего сообщения. Если idleEventInterval превышено, событие публикуется.
- person Gary Russell; 11.05.2016
