Method start

st2common/st2common/transport/consumers.py:195–200

(self, wait=False)

        self._consumer_thread = None

    def start(self, wait=False):
        LOG.info("Starting %s...", self.__class__.__name__)
        self._consumer_thread = concurrency.spawn(self._queue_consumer.run)

        if wait:
            self.wait()

    def wait(self):
        self._consumer_thread.wait()