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