amqp_tornado.py 文件源码

def connect(self):
        """This method connects to RabbitMQ, returning the connection handle.
        When the connection is established, the on_connection_open method
        will be invoked by pika.

        :rtype: pika.SelectConnection

        """
        log.info('Connecting to %s', self.amqp_url)
        return adapters.TornadoConnection(pika.URLParameters(self.amqp_url),
                                          self.on_connection_open)