pubsub.py 文件源码

def start(self):
        """Run the example consumer by connecting to RabbitMQ and then
        starting the IOLoop to block and allow the SelectConnection to operate.

        """

        pi('start')

        pc('self.connect')
        self._connection = self.connect()
        ps('self.connect')
        # self._connection.ioloop.start()

        pp(self, 'start')
        pr('start')