я вижу это реализовано через горутины, а до каких пор это будет читаться? то есть сколько одновременно сообщений один consumer сможет обрабатывать? если за раз в очередь будет добавлено 1000 сообщений?
Начиная с какого-то рейта раббит начнет тебя притормаживать через tcp backpressure
Один консумер одновременно обрабатывает одно сообщение, читаться будет пока в очереди есть Сообщения. И что значиться раз 1000 добавляется? В очередь сообщения добавляются по одному
Обсуждают сегодня