def run ( self ) : LOGGER . debug ( "rabbitmq.Service.run" ) try : self . channel . start_consuming ( ) except Exception as e : LOGGER . warn ( "rabbitmq.Service.run - Exception raised while consuming" )
rabbitmq python not ack
consume message from channel on the consuming thread .
def run(self):
        """
        consume message from channel on the consuming thread.
        """
        LOGGER.debug("rabbitmq.Service.run")
        try:
            self.channel.start_consuming()
        except Exception as e:
            LOGGER.warn("rabbitmq.Service.run - Exception raised while consuming")