Mercurial Repositories > MQTT Monitor / file comparison
comparison: MqttMonitor/MqttClient.py
MqttMonitor/MqttClient.py
- branch
- eric7
- changeset 95
- d830314cca87
- parent 92
- 2fb5c08019fd
- child 97
- 21f9c010dc42
equal
deleted
inserted
replaced
| 94:95b0b60d87ed | 95:d830314cca87 |
|---|---|
| 103 Private method to initialize the MQTT callback methods. | 103 Private method to initialize the MQTT callback methods. |
| 104 """ | 104 """ |
| 105 # TODO: add properties to signal | 105 # TODO: add properties to signal |
| 106 # TODO: MQTTv5: add support for MQTTv5 signature | 106 # TODO: MQTTv5: add support for MQTTv5 signature |
| 107 self.__mqttClient.on_connect = ( | 107 self.__mqttClient.on_connect = ( |
| 108 lambda client, userdata, flags, rc, properties: | 108 lambda client, userdata, flags, rc, properties=None: |
| 109 self.onConnect.emit(flags, rc)) | 109 self.onConnect.emit(flags, rc)) |
| 110 # TODO: MQTTv5: add support for MQTTv5 signature | 110 # TODO: MQTTv5: add support for MQTTv5 signature |
| 111 self.__mqttClient.on_disconnect = ( | 111 self.__mqttClient.on_disconnect = ( |
| 112 lambda client, userdata, rc: self.onDisconnected.emit(rc)) | 112 lambda client, userdata, rc: self.onDisconnected.emit(rc)) |
| 113 self.__mqttClient.on_log = ( | 113 self.__mqttClient.on_log = ( |
| 118 self.__mqttClient.on_publish = ( | 118 self.__mqttClient.on_publish = ( |
| 119 lambda client, userdata, mid: self.onPublish.emit(mid)) | 119 lambda client, userdata, mid: self.onPublish.emit(mid)) |
| 120 # TODO: add properties to signal | 120 # TODO: add properties to signal |
| 121 # TODO: MQTTv5: add support for MQTTv5 signature | 121 # TODO: MQTTv5: add support for MQTTv5 signature |
| 122 self.__mqttClient.on_subscribe = ( | 122 self.__mqttClient.on_subscribe = ( |
| 123 lambda client, userdata, mid, grantedQos, properties: | 123 lambda client, userdata, mid, grantedQos, properties=None: |
| 124 self.onSubscribe.emit(mid, grantedQos)) | 124 self.onSubscribe.emit(mid, grantedQos)) |
| 125 # TODO: MQTTv5: add support for MQTTv5 signature | 125 # TODO: MQTTv5: add support for MQTTv5 signature |
| 126 self.__mqttClient.on_unsubscribe = ( | 126 self.__mqttClient.on_unsubscribe = ( |
| 127 lambda client, userdata, mid: self.onUnsubscribe.emit(mid)) | 127 lambda client, userdata, mid: self.onUnsubscribe.emit(mid)) |
| 128 | 128 |
