Как закрыть очередь Kombu ConsumerMixin, подключенную к разветвленному обмену, чтобы не накапливать данные от издателя, пока мой потребитель не активен? Я использую Kombu 3.0.24 (с RabbitMQ) в Python 2.7. Ниже мой код для двух классов. Я бы...

У меня есть простое приложение, которое отправляет и получает сообщения, комбу и использует сельдерей для отправки сообщения. Комбу, я могу правильно принять сообщение. когда я посылаю «Привет», комбу получает «Привет». Но когда я добавил задачу,...

Я использую Kombu в Python для использования надежной очереди RabbitMQ. В Windows существует только один потребитель, использующий очередь. Этот потребитель выдает следующую ошибку: Traceback (most recent call last): File...

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