ebbe.bass
/
PiXelTubes
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixed mqtt 

Signed-off-by: Ebbe Baß <ebbe.bass>
main
Ebbe Baß 2024-02-18 00:07:04 +01:00
parent 3c8c048c45
commit 3e1f60fa22
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/app.py
View File

@ -114,16 +114,9 @@ def connect_mqtt():
return client return client
def mqtt_publisher(): def mqtt_publisher():
# Set Connecting Client ID
mqtt_client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
# client.username_pw_set(username, password)
mqtt_client.on_message = on_message
mqtt_client.connect("localhost", 1883)
# Create and start a thread for each universe # Create and start a thread for each universe
artnetBindIp = get_eth0_ip() artnetBindIp = get_eth0_ip()
artNet = Artnet.Artnet(BINDIP = artnetBindIp, DEBUG = True, SHORTNAME = "PiXelTubeMaster", LONGNAME = "PiXelTubeMaster", PORT = 6454) artNet = Artnet.Artnet(BINDIP = artnetBindIp, DEBUG = True, SHORTNAME = "PiXelTubeMaster", LONGNAME = "PiXelTubeMaster", PORT = 6454)
mqtt_client.subscribe("pxm/tube_index")
mqtt_client.loop_start()
while True: while True:
try: try:
# Gets whatever the last Art-Net packet we received is # Gets whatever the last Art-Net packet we received is
@ -166,4 +159,7 @@ if __name__ == "__main__":
update_tube_index_thread.start() update_tube_index_thread.start()
flask_thread = Process(target=flask_api) flask_thread = Process(target=flask_api)
flask_thread.start() flask_thread.start()
mqtt_client = connect_mqtt()
mqtt_client.subscribe("pxm/tube_index")
mqtt_client.loop_start()
mqtt_publisher() mqtt_publisher()