web.py 文件源码

def connect(self):
        if self.connecting:
            return
        self.connecting = True
        param = pika.ConnectionParameters(host=settings.RABBITMQ_HOST)
        self.connection = pika.adapters.tornado_connection.TornadoConnection(
            param,
            on_open_callback=self.on_connected,
            on_open_error_callback=self.on_connection_error,
            on_close_callback=self.close)