Skip to content
Snippets Groups Projects
Commit 1e1dff1f authored by Torben Petersen's avatar Torben Petersen
Browse files

Coordinator now uses seld.server to generate rx topics

parent 045001b3
No related branches found
No related tags found
No related merge requests found
......@@ -180,7 +180,7 @@ class PRREvalClient(Thread):
self.client.on_disconnect = self.on_disconnect
self.client.loop_start()
self.server = "pc13"
self.server = "pi-a279"
self.HUB_DISCOVERY_TOPIC = "hotplug/{}/discovery".format(self.server)
self.HUB_DISCOVERY_ANSWER_TOPIC = "hotplug/{}/discovery/answer".format(self.server)
......@@ -207,10 +207,10 @@ class PRREvalClient(Thread):
self.logger.debug("Got nodes: {}".format(all_nodes))
for node in all_nodes:
if node not in self.my_nodes and node is not '':
self.logger.debug("Subscribing!")
self.my_nodes.append(node)
rx_topic = "hotplug/pc13/{}/rx".format(node)
rx_topic = "hotplug/{}/{}/rx".format(self.server, node)
self.client.subscribe(rx_topic, qos=2)
self.logger.debug("Subscribing to {}!".format(rx_topic))
print("My Nodes: {}".format(self.my_nodes))
elif topic[0] == "hotplug" and len(topic) == 4:
unpacked_msg = str(msg.payload)[2:][:-1]
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment