import paho.mqtt.client as mqtt
import time
############
#message.topic="/controls/light1/cmnd/POWER"
def on_message(client, userdata, message):
    print("message received " ,str(message.payload.decode("utf-8")))
    print("message topic=",message.topic)
    print("message qos=",message.qos)
    print("message retain flag=",message.retain)
########################################
broker_address="hairdresser.cloudmqtt.com" #use external broker
print("creating new instance")

client = mqtt.Client("P1") #create new instance
client.on_message=on_message
client.username_pw_set(username="zjqvfibx", password="aXRFsHdgZcrB")
print("connecting to broker")
client.connect(broker_address, 16583) #connect to broker
client.loop_start()
print("Subscribing to topic","/controls/light1/stat/POWER")
client.subscribe("/controls/light1/stat/POWER")
print("Publishing message to topic","/controls/light1/cmnd/POWER")
client.publish("/controls/light1/cmnd/POWER","OFF")#publish

#time.sleep(3)
#client.publish("/controls/light1/cmnd/POWER","OFF")#publish
client.loop_stop()