одном треде и вроде как консьюмеров 10, а выполняют работу они последовательно.
Пробовал работу консьюмера выносить в корутины , но тогда происходит неконтролируемый рост корутин и консьюмер отрабатывает очень быстро, по сути берет месадж из очереди и запускает корутину, дальше берет сразу следующий месадж.
По сути мне нужно запустить работу ребита в корутине, чтоб не блочить тред, но что б консьюмер ждал выполнения работы и только после этого консьюмил сл месадж
в этом подходе проблема в том, что я не могу сделать async await в не suspend функции
использую пакет com.rabbitmq.client
Как кой правильный путь? Гугл не дает ответа(
вот эту либу возьмите
Обсуждают сегодня