code: def start_consuming(self, to_tuple=False, auto_decode=True):
          
          while not self.is_closed:
              self.process_data_events(
                  to_tuple=to_tuple,
                  auto_decode=auto_decode
              )
              if self.consumer_tags:
                  sleep(IDLE_WAIT)
                  continue
              break
docs: Start consuming messages.
  
          :param bool to_tuple: Should incoming messages be converted to a
                                tuple before delivery.
          :param bool auto_decode: Auto-decode strings when possible.
  
          :raises AMQPChannelError: Raises if the channel encountered an error.
          :raises AMQPConnectionError: Raises if the connection
                                       encountered an error.
  
          :return: