Python-сообщество

Привет.
Есть rabbitmq, очерь, продьюсер и косньюмер.

Смысл в том, консьюмер забирает из очереди таски, и начинает их делать(мультипроцессинг),
то после какой-то итерации консьюмер перестает очередь слушать, он демонизирован, просто весит и все, а в очереди сообщения есть.

Таски делаются 2-3 минуты, пробовал heartbeat крутить: выключать, ставить большой(не помогло), пробовал делать sleep в connection в 500 секунд, не помогло.

Были ли у вас подобные проблемы?
Буду рад советам

вы используете celery?
Долгие такси это по времени сколько?

JOHN_16
вы используете celery?Долгие такси это по времени сколько?

Используй неблокирующую очередь и тести на try-except'е в цикле.

 # Life loop
while alive:
    if (fun > boredom) and money:
        pass_day(fun, boredom, money)
        continue
    else: break