code: def start(self, *args, **kwargs):#pylint:disable=unused-argument
          
          forever = kwargs.get('forever', True)
          timeout = kwargs.get('timeout', None)
          if forever:
              return self.run(timeout=timeout)
          elif timeout:
              next((self.consume(timeout=timeout)), None)
          else:
              next((self.consume(limit=1, timeout=timeout)), None)
docs: | Launch the consumer.
          | It can listen forever for messages or just wait for one.
  
          :param forever: If set, the consumer listens forever. Default to `True`.
          :type forever: bool
          :param timeout: If set, the consumer waits the specified seconds before quitting.
          :type timeout: None, int
          :rtype: None
          :raises socket.timeout: when no message has been received since `timeout`.