rabbitmq.py 文件源码

def connect(self):
        connection = pika.BlockingConnection(
            pika.ConnectionParameters(
                host=self.conf.rabbitmq_host,
                port=self.conf.rabbitmq_port,
                credentials=self.credentials(),
                ssl=False)
        )
        self.channel = connection.channel()