docs: def run(self):
          '''Run listener
          '''
  
          self.running = True
  
          for msg in self.recv(1):
              if msg is None:
                  if self.running:
                      continue
                  else:
                      break
  
              self.logger.debug("New message received: %s", str(msg))
              self.add_to_queue(msg)