def run(self):
        """
        actual consuming of incoming works starts here
        """
        self.input_channel.basic_consume(self.handle_message,
                                         queue=self.INPUT_QUEUE_NAME,
                                         no_ack=True
                                         )
        try:
            self.input_channel.start_consuming()
        except (KeyboardInterrupt, SystemExit):
            log.info(" Exiting")
            self.exit()
def run ( self ) : self . input_channel . basic_consume ( self . handle_message , queue = self . INPUT_QUEUE_NAME , no_ack = True ) try : self . input_channel . start_consuming ( ) except ( KeyboardInterrupt , SystemExit ) : log . info ( " Exiting" ) self . exit ( )
actual consuming of incoming works starts here