import sys
import paho.mqtt.client as mqtt
import time



def on_log(client, userdata, level, buf):
    print("log: ",buf)

client = mqtt.Client()
client.username_pw_set(username ="emonpi",password ="emonpimqtt2016")
client.connect("127.0.0.1",1883, 60)
client.loop_start()

while True:
    client.on_log=on_log
    topic = "emon/TEST/M1"
    payload = "1.1850"
    client.subscribe(topic)
    client.publish(topic, payload=payload, qos=0, retain=False)
    time.sleep(6.0)
    payload = "0.1850"
    client.publish(topic, payload=payload, qos=0, retain=False)
    time.sleep(6.0)
client.loop_stop()