Я правильно понимаю, что если сообщения добавляются в очередь по

одному, то раббит сам не сможет их слать консюмеру батчами по нескольку штук за раз?

не правильно

А вам конкретно для чего батч, вы с какой проблемой столкнулись?

Мне в консюмере нужно дождаться нескольких посылок, чтобы потом переслать их одним TCP пакетом.

ну и дожидайтесь) просто префетч сделайте больше чем батч

Так а зачем тогда вообще нужен батч?

ну вот это я у вас и спрашиваю. у меня кейс что сообщения нужно кидать батчами, чтобы снизить нагрузку с клика

Может, кафку юзать тогда?

А я вроде не спрашивал что мне делать, я пытался в вашем кейсе разобраться. Со своим у меня всё в порядке. Многое можно, а вот пох*й на всё! (С) Пневмослон

Я не пойму, умеет ли сам раббит или amqp собирать сообщения в батч или мне нужно руками это делать? Руками слишком много нюансов всплывает, нужно хранить все теги, динамически менять префетч. Неужели для этого нет готового механизма?

Что за теги? Консьюмер-теги? Зачем их хранить?

Ну акать-то их надо по отдельности =)

Почему по отдельности? Можно же ack(multiple = true).

Такое себе =)

А тут я подводил к тому, что либа сама этим "хранением" занимается. Запускаешь консьюмер и ловишь сообщения.

Если один консюмер шлёт в 2 разных места, то так уже не выйдет.

Тогда нужны две разные очереди.

Уже думал над этим. А что если порядка 1000 очередей?

А в чем проблема?