# pip install paho-mqtt
import time
import paho.mqtt.client as mqtt # import the client1

broker_address = "mosquito.tiburcio.mx"
broker_port = 1883
topic = "notification"

def on_message(client, userdata, message):
 print("Mensaje recibido=", str(message.payload.decode("utf-8")))
 print("Topic=", message.topic)

client = mqtt.Client("Subscriptor1")
client.on_message = on_message 
client.connect(host=broker_address,port=1883) 
#client.loop_start() # Inicio del bucle
client.subscribe(topic)
#time.sleep(10) # Paramos el hilo para recibir mensajes.
client.loop_forever() # Fin del bucle
