code: def _start_consumer(self, consumer):
          
          thread = threading.Thread(target=consumer.start,
                                    args=(self._connection,))
          thread.daemon = True
          thread.start()
docs: Start a consumer as a new Thread.
  
          :param Consumer consumer:
          :return: