def METHOD_NAME(self) -> None:
    with configure_scope() as scope, log_and_exit_if_exception(
        self.logger, self.queue_name, threaded=True
    ):
        scope.set_tag("queue_worker", self.worker.queue_name)
        self.worker.setup()
        logging.debug("starting consuming %s", self.worker.queue_name)
        self.worker.start()