Method run

eventhandlers/ConsumersCreator.py:133–152

Run the example code by connecting and then starting the IOLoop.

(self)

        )

    def run(self):
        """Run the example code by connecting and then starting the IOLoop.
        """
        while not self.stopping:
            self.connection = None
            self.deliveries = {}
            self.acked = 0
            self.nacked = 0
            self.message_number = 0

            try:
                self.create_consumers()
                self.connection.ioloop.start()
            except KeyboardInterrupt:
                self.stop()
                if (self.connection is not None and
                    not self.connection.is_closed):
                    self.connection.ioloop.start()

        logger.info('Stopped')

    def stop_processing(self):
        self.channel.stop_consuming()