Mercurial Repositories > MQTT Monitor / file comparison
comparison: PluginMqttMonitor.py
PluginMqttMonitor.py
- branch
- eric7
- changeset 106
- 84498095d511
- parent 105
- 36ec7431ad04
- child 111
- f19934855f45
equal
deleted
inserted
replaced
| 105:36ec7431ad04 | 106:84498095d511 |
|---|---|
| 141 "UnsubscribeProperties": "{}", # JSON formatted empty dict | 141 "UnsubscribeProperties": "{}", # JSON formatted empty dict |
| 142 # __IGNORE_WARNING_M613__ | 142 # __IGNORE_WARNING_M613__ |
| 143 "DefaultProtocol": MqttProtocols.MQTTv311, | 143 "DefaultProtocol": MqttProtocols.MQTTv311, |
| 144 "RecentBrokersNumber": 20, | 144 "RecentBrokersNumber": 20, |
| 145 "RecentTopicsNumber": 20, | 145 "RecentTopicsNumber": 20, |
| 146 "RecentTopics": "[]", # JSON formatted empty list | |
| 146 } | 147 } |
| 147 | 148 |
| 148 self.__translator = None | 149 self.__translator = None |
| 149 self.__loadTranslator() | 150 self.__loadTranslator() |
| 150 | 151 |
| 162 @rtype tuple of (None, bool) | 163 @rtype tuple of (None, bool) |
| 163 """ | 164 """ |
| 164 global error, mqttPluginObject | 165 global error, mqttPluginObject |
| 165 error = "" # clear previous error | 166 error = "" # clear previous error |
| 166 mqttPluginObject = self | 167 mqttPluginObject = self |
| 167 | |
| 168 | 168 |
| 169 try: | 169 try: |
| 170 import paho.mqtt # __IGNORE_WARNING__ | 170 import paho.mqtt # __IGNORE_WARNING__ |
| 171 except ImportError: | 171 except ImportError: |
| 172 error = self.tr("The 'paho-mqtt' package is not available.") | 172 error = self.tr("The 'paho-mqtt' package is not available.") |
| 262 @return value of the requested setting | 262 @return value of the requested setting |
| 263 @rtype Any | 263 @rtype Any |
| 264 """ | 264 """ |
| 265 if key in ("RecentBrokersWithPort", "BrokerProfiles", | 265 if key in ("RecentBrokersWithPort", "BrokerProfiles", |
| 266 "SubscribeProperties", "UnsubscribeProperties", | 266 "SubscribeProperties", "UnsubscribeProperties", |
| 267 "PublishProperties"): | 267 "PublishProperties", "RecentTopics"): |
| 268 return json.loads(Preferences.Prefs.settings.value( | 268 return json.loads(Preferences.Prefs.settings.value( |
| 269 self.PreferencesKey + "/" + key, self.__defaults[key])) | 269 self.PreferencesKey + "/" + key, self.__defaults[key])) |
| 270 elif key in ("DefaultProtocol", ): | 270 elif key in ("DefaultProtocol", ): |
| 271 return MqttProtocols(int(Preferences.Prefs.settings.value( | 271 return MqttProtocols(int(Preferences.Prefs.settings.value( |
| 272 self.PreferencesKey + "/" + key, self.__defaults[key]))) | 272 self.PreferencesKey + "/" + key, self.__defaults[key]))) |
| 287 @param value value to be set | 287 @param value value to be set |
| 288 @type Any | 288 @type Any |
| 289 """ | 289 """ |
| 290 if key in ("RecentBrokersWithPort", "BrokerProfiles", | 290 if key in ("RecentBrokersWithPort", "BrokerProfiles", |
| 291 "SubscribeProperties", "UnsubscribeProperties", | 291 "SubscribeProperties", "UnsubscribeProperties", |
| 292 "PublishProperties"): | 292 "PublishProperties", "RecentTopics"): |
| 293 Preferences.Prefs.settings.setValue( | 293 Preferences.Prefs.settings.setValue( |
| 294 self.PreferencesKey + "/" + key, json.dumps(value)) | 294 self.PreferencesKey + "/" + key, json.dumps(value)) |
| 295 elif key in ("DefaultProtocol", ): | 295 elif key in ("DefaultProtocol", ): |
| 296 Preferences.Prefs.settings.setValue( | 296 Preferences.Prefs.settings.setValue( |
| 297 self.PreferencesKey + "/" + key, int(value)) | 297 self.PreferencesKey + "/" + key, int(value)) |
