def __init__(self, options):
self.messages = []
self.receiveTopic = options["control_topic"]+"/receive"
self.sendTopic = options["control_topic"]+"/send"
self.sendProxyTopic = options["proxy_control_topic"]+"/receive"
self.client = mqtt.Client("control_connection")
self.client.on_message = self.on_message
self.client.on_connect = self.on_connect
self.client.on_publish = self.on_publish
self.controlBrokerHost, self.controlBrokerPort = options["control_connection"].split(":")
self.controlBrokerPort = int(self.controlBrokerPort)
self.ready = False
self.client.connect(self.controlBrokerHost, self.controlBrokerPort, 60)
self.published = False
self.client.loop_start()
while not self.ready:
time.sleep(.4)
评论列表
文章目录