MQTT Subscribe and Post

[pythoncoder]

c.wait_msg() is a blocking function: this means it won't return until a message is received. This prevents you from publishing while waiting for a message. The way to proceed is to use c.check_msg(). This returns immediately. If a message has been received the callback will run as before. So your main loop might look like

Code: Select all

try:
    while 1:
        c.check_msg()
        if door_has_opened():  # Detect change of state
            c.publish(b"door", b"open")
        if door_has_closed():
            c.publish(b"door", b"closed")
        time.sleep(0.2)  # Avoid 100% CPU usage
    finally:
        c.disconnect()