import paho.mqtt.client as mqttClient
import time

######################################################################## 
def on_connect(client, userdata, flags, rc):
 
    if rc == 0:
        print("Connected to broker")
        global Connected               
        Connected = True                
 
    else:
        print("Connection failed")
########################################################################
def on_publish(client,userdata,result):
    print("data published \n")
    pass
########################################################################
 
Connected = False

broker_address= "localhost"
port = 1883

client = mqttClient.Client("Python_publisher")     #create new instance
client.on_connect= on_connect                      #attach function to callback
client.on_publish = on_publish                     #attach function to callback 
client.connect(broker_address, port=port)          #connect to broker
client.loop_start()                                #start the loop
 
while Connected != True:                           #Wait for connection
    time.sleep(0.1)
 
client.publish("test/message", payload="hello")
#-------------------------------------------------------------------------
try:
    while True:
        print("publishing to test/message")
        client.publish("test/message", payload="hello")
        time.sleep(1)
#-------------------------------------------------------------------------
except KeyboardInterrupt:
    print("exiting")
    client.disconnect()
    client.loop_stop()