def stop(self):
        if not self._consumers_ready.ready():
            _log.debug('stopping while consumer is starting %s', self)

            stop_exc = QueueConsumerStopped()

            # stopping before we have started successfully by brutally
            # killing the consumer thread as we don't have a way to hook
            # into the pre-consumption startup process
            self._gt.kill(stop_exc)

        self.wait_for_providers()

        try:
            _log.debug('waiting for consumer death %s', self)
            self._gt.wait()
        except QueueConsumerStopped:
            pass

        super(QueueConsumer, self).stop()
        _log.debug('stopped %s', self)
Get ca_id to be used with GetCaParameters().
dataset/ETHPy150Open onefinestay/nameko/nameko/messaging.py/QueueConsumer.stop--crossover with--dataset/ETHPy150Open google/simian/src/simian/auth/util.py/GetCaId