publish cache

2025-12-06 14:34:52 +01:00
parent ca08059e13
commit 6d8c5c25db
3 changed files with 11 additions and 2 deletions
--- a/src/pv_controller/FromDevices.py
+++ b/src/pv_controller/FromDevices.py
@@ -52,7 +52,7 @@ class FromDevices(AbstractMqttPublisher):
                    payload['cnt'] = cnt
                
                    payloadStr = json.dumps(payload) if not device.raw_output else str(payload['output'])
-                    self.client.publish(device.publish_topic, payloadStr)
+                    self.publish_with_cache(device.publish_topic, payloadStr)
                    logger.debug(f"mqtt message sent: {device.publish_topic} -> {payloadStr}")
                except Exception as e:
                    logger.error(f"Caught exception: {str(e)}")