plugin_mqtt: Change config type to use typed address configuration

Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>

2 files changed, 2 insertions, 2 deletions

diff --git a/plugins/plugin_mqtt/src/builder.rs b/plugins/plugin_mqtt/src/builder.rs
index 3ef4c86d..2bdcece1 100644
--- a/plugins/plugin_mqtt/src/builder.rs
+++ b/plugins/plugin_mqtt/src/builder.rs
@@ -61,7 +61,7 @@ where
             .try_into::<MqttConfig>()
             .map_err(crate::error::Error::ConfigParseFailed)?;
 
-        let addr = plugin_dir.get_address_for(&config.target)?;
+        let addr = config.target.build(plugin_dir)?;
         Ok(MqttPlugin::new(config, addr).finish())
     }
 }
diff --git a/plugins/plugin_mqtt/src/config.rs b/plugins/plugin_mqtt/src/config.rs
index 7e8d6d74..b93129bb 100644
--- a/plugins/plugin_mqtt/src/config.rs
+++ b/plugins/plugin_mqtt/src/config.rs
@@ -9,7 +9,7 @@ pub struct MqttConfig {
     pub subscriptions: Vec<Subscription>,
 
     /// Name of the plugin to send messages to
-    pub target: String,
+    pub target: tedge_lib::config::Address,
 }
 
 #[derive(Debug, serde::Deserialize, tedge_api::Config)]