Deal with close and connection problem in MQTT source

[sanha]

We need to deal with connection problem in MQTTSubscribeClient. Also, we need to introduce some kind of reference count to MQTTDataGenerator considering it's close() method. (this count should be thread-safe)

[sanha]

We have to consider that the connection between MIST and MQTT broker can be closed sometime.