Mercurial Repositories > MQTT Monitor / file comparison
comparison: MqttMonitor/MqttClient.py
MqttMonitor/MqttClient.py
- changeset 11
- 90d3ebed4cc0
- parent 10
- 7e0e921dc7ea
- child 22
- 545979c7dcd4
equal
deleted
inserted
replaced
| 10:7e0e921dc7ea | 11:90d3ebed4cc0 |
|---|---|
| 61 | 61 |
| 62 self.__mqttClient = mqtt.Client( | 62 self.__mqttClient = mqtt.Client( |
| 63 client_id=clientId, clean_session=cleanSession, userdata=None, | 63 client_id=clientId, clean_session=cleanSession, userdata=None, |
| 64 protocol=mqtt.MQTTv311, transport="tcp") | 64 protocol=mqtt.MQTTv311, transport="tcp") |
| 65 | 65 |
| 66 self.__initCallbacks() | |
| 67 | |
| 68 def __initCallbacks(self): | |
| 69 """ | |
| 70 Private method to initialize the MQTT callback methods. | |
| 71 """ | |
| 66 self.__mqttClient.on_connect = \ | 72 self.__mqttClient.on_connect = \ |
| 67 lambda client, userdata, flags, rc: self.onConnect.emit( | 73 lambda client, userdata, flags, rc: self.onConnect.emit( |
| 68 flags, rc) | 74 flags, rc) |
| 69 self.__mqttClient.on_disconnect = \ | 75 self.__mqttClient.on_disconnect = \ |
| 70 lambda client, userdata, rc: self.onDisconnected.emit(rc) | 76 lambda client, userdata, rc: self.onDisconnected.emit(rc) |
| 90 @param userdata user data | 96 @param userdata user data |
| 91 @type any | 97 @type any |
| 92 """ | 98 """ |
| 93 self.__mqttClient.reinitialise( | 99 self.__mqttClient.reinitialise( |
| 94 client_id=clientId, clean_session=cleanSession, userdata=userdata) | 100 client_id=clientId, clean_session=cleanSession, userdata=userdata) |
| 101 | |
| 102 self.__initCallbacks() | |
| 95 | 103 |
| 96 def setMaxInflightMessages(self, inflight=20): | 104 def setMaxInflightMessages(self, inflight=20): |
| 97 """ | 105 """ |
| 98 Public method to set the maximum number of messages with QoS > 0 that | 106 Public method to set the maximum number of messages with QoS > 0 that |
| 99 can be part way through their network flow at once. | 107 can be part way through their network flow at once. |
