def on_disconnect(self, client, userdata, rc):
    info('mqtt', 'on_disconnect')
    if (rc != MQTT_ERR_SUCCESS):
        info('mqtt', ('on_disconnect unexpected: ' + str(rc)))
def on_disconnect(self, client, userdata, rc):
    info('mqtt', 'on_disconnect')
    if (rc != MQTT_ERR_SUCCESS):
        info('mqtt', ('on_disconnect unexpected: ' + str(rc)))