Bandicoot
@Bandicoot
Вась-программист

Как получить все элементы очереди RabbitMQ?

Необходимо через определенный интервал считывать содержимое очереди и выгружать его в базу. После этого очередь очищается и заполняется по новой.

Подскажите пожалуйста, как реализовать. В документации не нашел, хотя может быть плохо искал.
  • Вопрос задан
  • 61 просмотр
Пригласить эксперта
Ответы на вопрос 1
inoise
@inoise
Solution Architect, AWS Certified, Serverless
Нельзя получить "все сообщения из очереди". Получаете их по очереди без ack, записываете в базу, потом делаете ack. Можно посмотреть в сторону метода basic.consume.

А вообще вы же с очередью работаете. Не надо делать батч из очереди. Это противоестественно. Особенно учитывая что размер очереди изначально не известен
Ответ написан
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы