01-con-discon-success.test

#!/usr/bin/env python

import os
import subprocess
import socket
import sys
import time
from struct import *

import paho.mqtt.client as mqtt


def on_connect(mqttc, obj, flags, rc):
    if rc != 0:
        exit(rc)
    else:
        mqttc.disconnect()

def on_disconnect(mqttc, obj, rc):
    mqttc.loop()
    obj = rc


run = -1
mqttc = mqtt.Client("01-con-discon-success", run, protocol=mqtt.MQTTv31)
mqttc.on_connect = on_connect
mqttc.on_disconnect = on_disconnect

mqttc.connect("localhost", 1888)
while run == -1:
    mqttc.loop()

exit(run)