import paho.mqtt.client as mqtt
import time

def on_connect(client, obj, flags, rc):
    print ("We are connected to the broker")
    client.subscribe("sds011/#", 0)


def on_subscribe(client, userdata, mid, granted_qos):
    print ('Subscribed:', userdata, mid, granted_qos)
    print ('We have subscribed to topics, waiting...to be killed')


th_abort = False
client = mqtt.Mosquitto()
client.on_connect = on_connect
client.on_subscribe = on_subscribe
resp = client.connect('127.0.0.1', 1883, 60)

client.loop_start()
result, mid = client.publish("sds011/data", "Just testing MQTT", 0)


while not th_abort:
    time.sleep(0.1)
client.loop_stop()
client.disconnect()
print ("test script stopped...")
exit()