Канал Пика перестает потреблять через некоторое время - PullRequest
Новая
       7

Канал Пика перестает потреблять через некоторое время

2 голосов
/ 07 января 2020

У меня есть канал Pika, прослушивающий очередь RabbitMQ: 

credentials = pika.PlainCredentials(user, passwd)
connection = pika.BlockingConnection(
        pika.ConnectionParameters(host=host,
                                  port=port,
                                  credentials=credentials,
                                  heartbeat=0))
channel = connection.channel()

channel.basic_consume(on_message_callback=callbackFun,
                      queue=queue,
                      auto_ack=True)

channel.start_consuming()

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

Как мне избежать этого поведения?

...