Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def run():
- # Mqtt
- client = mqtt.Client()
- client.on_connect = on_connect
- client.on_message = on_message
- client.username_pw_set("/virtualhost:username", "password")
- client.connect("rmqserver", port, 60)
- client.loop_forever()
- try:
- run()
- except:
- print("connection failed")
- time.sleep(45)
- run()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement