Я создаю систему массовой обработки видео с использованием Spring-Boot.Здесь пользователь предоставит всю информацию, связанную с видео, через лист xlsx, и мы обработаем видео в бэкэнде.Я использую Rabbitmq для постановки в очередь запроса.Допустим, пользователь загрузил лист с 100 строками, тогда в очереди Rabbitmq будет 100 сообщений.В конце мы автоматически масштабируем подписчиков (серверы).Поэтому мы начнем с одного подписчика и, исходя из загрузки (количества сообщений в очереди), мы будем масштабировать до 15 подписчиков.Но наш продюсер работает очень быстро и распределяет все сообщения нашему первому подписчику (до появления других подписчиков), и все наши новые подписчики не получают никаких сообщений из очереди.Если все подписчики доступны до того, как производитель начал отправлять сообщения, он распределяет сообщения по всем серверам.
Пожалуйста, предоставьте мне решение, как наши новые подписчики могут извлекать сообщения из очереди, которые были созданы ранее.