Mercurial Repositories > MQTT Monitor / file diff

--- a/MqttMonitor/MqttClient.py	Sat Sep 01 20:18:11 2018 +0200
+++ b/MqttMonitor/MqttClient.py	Sun Sep 02 18:29:35 2018 +0200
@@ -63,6 +63,12 @@
             client_id=clientId, clean_session=cleanSession, userdata=None,
             protocol=mqtt.MQTTv311, transport="tcp")
         
+        self.__initCallbacks()
+
+    def __initCallbacks(self):
+        """
+        Private method to initialize the MQTT callback methods.
+        """
         self.__mqttClient.on_connect = \
             lambda client, userdata, flags, rc: self.onConnect.emit(
                 flags, rc)
@@ -92,6 +98,8 @@
         """
         self.__mqttClient.reinitialise(
             client_id=clientId, clean_session=cleanSession, userdata=userdata)
+        
+        self.__initCallbacks()
     
     def setMaxInflightMessages(self, inflight=20):
         """