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

Question

[Crash]

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

Подскажите пожалуйста, как реализовать. В документации не нашел, хотя может быть плохо искал.

Answer 1

[Иван Шумов]

Нельзя получить "все сообщения из очереди". Получаете их по очереди без ack, записываете в базу, потом делаете ack. Можно посмотреть в сторону метода basic.consume.

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