diff --git a/packages/modules/chargepoints/mqtt/chargepoint_module.py b/packages/modules/chargepoints/mqtt/chargepoint_module.py index a402a4ba64..8f865b29c3 100644 --- a/packages/modules/chargepoints/mqtt/chargepoint_module.py +++ b/packages/modules/chargepoints/mqtt/chargepoint_module.py @@ -27,7 +27,7 @@ def set_current(self, current: float) -> None: def get_values(self) -> None: with SingleComponentUpdateContext(self.fault_state): def on_connect(client, userdata, flags, rc): - client.subscribe(f"openWB/mqtt/chargepoint/{self.config.id}/#") + client.subscribe(f"openWB/mqtt/chargepoint/{self.config.id}/get/#") def on_message(client, userdata, message): received_topics.update({message.topic: decode_payload(message.payload)}) @@ -62,7 +62,9 @@ def on_message(client, userdata, message): ) self.store.set(chargepoint_state) else: - raise Exception(f"Keine MQTT Daten für Gerät {self.config.id} empfangen") + raise Exception(f"Keine MQTT Daten für Ladepunkt {self.config.name} empfangen oder es werden veraltete " + "Topics verwendet. Diese funktionieren mit Einschränkungen trotz dieser Fehlermeldung. " + "Bitte die Doku in den Einstellungen beachten.") def switch_phases(self, phases_to_use: int, duration: int) -> None: Pub().pub(f"openWB/mqtt/chargepoint/{self.config.id}/set/phases_to_use", phases_to_use) diff --git a/packages/modules/devices/generic/mqtt/device.py b/packages/modules/devices/generic/mqtt/device.py index cbf21b1124..d6c5509bde 100644 --- a/packages/modules/devices/generic/mqtt/device.py +++ b/packages/modules/devices/generic/mqtt/device.py @@ -40,10 +40,10 @@ def on_message(client, userdata, message): for component in components: component.update(received_topics) else: - for component in components: - component.fault_state.warning( - f"Keine MQTT-Daten für Gerät {device_config.id} empfangen oder es werden veraltete legacy-Topics" - " verwendet. Bitte die Doku in den Einstellungen beachten.") + raise Exception( + f"Keine MQTT-Daten für Gerät {device_config.id} empfangen oder es werden veraltete Topics" + " verwendet. Diese funktionieren mit Einschränkungen trotz dieser Fehlermeldung. Bitte die Doku in " + "den Einstellungen beachten.") return ConfigurableDevice( device_config=device_config,