amqpstorm

1熱度

1回答

兔子消費者停止使用channel.basic.ack

我使用python 3和amqpstorm包。我有這樣一段代碼（縮寫）具有開放的RabbitMQ連接工作： ichannel = connection.channel(rpc_timeout = 5) ichannel.basic.qos(10000) ichannel.queue.bind(...) ichannel.basic.consume(self.<process_message>