def config_update(self, config):
self.config = config
self.mqtt_qos_publish = int(self.config['mqtt_qos_publish']) if 'mqtt_qos_publish' in config else 0
self.mqtt_qos_subscribe = int(self.config['mqtt_qos_subscribe']) if 'mqtt_qos_subscribe' in config else 0
self.mqtt_retain = 'mqtt_retain' in config and self.config['mqtt_retain']
if 'api_url' in config:
self.api_url = config['api_url']
thread.start_new_thread(self.api_login, ())
if self.mqtt_client:
self.mqtt_client.disconnect()
else:
self.mqtt_connect()
评论列表
文章目录