code: def recv(self, topic, payload, qos):
          
          data = self._parse_mqtt_to_message(topic, payload, qos)
          if data is None:
              return
          _LOGGER.debug('Receiving %s', data)
          self.add_job(self.logic, data)
docs: Receive a MQTT message.
  
          Call this method when a message is received from the MQTT broker.