if __name__ == "__main__":
    n1 = mqtt.Client("node1")
    n1.username_pw_set("user", "pass")

    m = mqtt.Client("manager")
    m.username_pw_set("user", "pass")

    n1.connect("kasparov-dev-auxiliary-default.daglabs.com")
    m.connect("kasparov-dev-auxiliary-default.daglabs.com")

    def on_message(client, userdata, message):
        print(message.topic)
        print(message.payload)
    m.on_message = on_message
    m.subscribe("Home/Toilet")
    m.loop_start()

    m.publish("Home/Toilet", "Flush") #getting callback
    n1.publish("Home/Toilet", "Wipe") #not getting callback
    time.sleep(6)