Only replace topic

This commit is contained in:
Nick Mowen 2023-01-03 15:20:22 -07:00
parent ceab294840
commit 564145dc75

View File

@ -85,7 +85,7 @@ class MqttClient(Communicator): # type: ignore[misc]
self, client: mqtt.Client, userdata: Any, message: mqtt.MQTTMessage
) -> None:
self._dispatcher(
message.topic.replace(f"{self.mqtt_config.topic_prefix}/", ""),
message.topic.replace(f"{self.mqtt_config.topic_prefix}/", "", 1),
message.payload.decode(),
)