From 9e3be40a444d7ee80b70b88b939decb036c21b1b Mon Sep 17 00:00:00 2001 From: Evgeny Zinoviev Date: Wed, 26 Apr 2023 14:30:28 +0300 Subject: mqtt receivers: call parent on_message function for debugging purposes --- src/inverter_mqtt_receiver.py | 1 + src/sensors_mqtt_receiver.py | 1 + 2 files changed, 2 insertions(+) diff --git a/src/inverter_mqtt_receiver.py b/src/inverter_mqtt_receiver.py index d138609..a7018f2 100755 --- a/src/inverter_mqtt_receiver.py +++ b/src/inverter_mqtt_receiver.py @@ -20,6 +20,7 @@ class MQTTReceiver(MQTTBase): client.subscribe('hk/#', qos=1) def on_message(self, client: mqtt.Client, userdata, msg): + super().on_message(client, userdata, msg) try: match = re.match(r'(?:home|hk)/(\d+)/(status|gen)', msg.topic) if not match: diff --git a/src/sensors_mqtt_receiver.py b/src/sensors_mqtt_receiver.py index 0b4c279..9637690 100755 --- a/src/sensors_mqtt_receiver.py +++ b/src/sensors_mqtt_receiver.py @@ -27,6 +27,7 @@ class MQTTServer(MQTTBase): client.subscribe('hk/#', qos=1) def on_message(self, client: mqtt.Client, userdata, msg): + super().on_message(client, userdata, msg) try: variants = '|'.join([s.name.lower() for s in TemperatureSensorLocation]) match = re.match(rf'hk/(\d+)/si7021/({variants})', msg.topic) -- cgit v1.2.3