code: def consume(self, queue_name, prefetch=1, timeout=5000):
          
          return _RedisConsumer(self, queue_name, prefetch, timeout)
docs: Create a new consumer for a queue.
  
          Parameters:
            queue_name(str): The queue to consume.
            prefetch(int): The number of messages to prefetch.
            timeout(int): The idle timeout in milliseconds.
  
          Returns:
            Consumer: A consumer that retrieves messages from Redis.