rabbitmq.py 文件源码

def connect(self):
        params = pika.URLParameters(os.environ['RABBITMQ_CONNECTION'])
        self._connection = pika.BlockingConnection(params)
        self._channel = self._connection.channel()
        self._connected = True