summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@ifm.com>2022-05-18 15:21:29 +0200
committerMatthias Beyer <matthias.beyer@ifm.com>2022-05-23 12:17:59 +0200
commit7d1e1be2004eabd74422f1ac1829fdfe964e9ae1 (patch)
treea0bca94476811abd8f52779145e5631d253089ba
parent8cfce62c8dfaaf2986aa122bc80ac465b1e46b55 (diff)
plugin_mqtt_measurement_bridge: Change config type to use typed address configuration
Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>
-rw-r--r--plugins/plugin_mqtt_measurement_bridge/src/lib.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/plugin_mqtt_measurement_bridge/src/lib.rs b/plugins/plugin_mqtt_measurement_bridge/src/lib.rs
index 7843ae13..3ba430ac 100644
--- a/plugins/plugin_mqtt_measurement_bridge/src/lib.rs
+++ b/plugins/plugin_mqtt_measurement_bridge/src/lib.rs
@@ -75,7 +75,7 @@ where
.try_into::<MqttMeasurementBridgeConfig>()
.map_err(Error::ConfigParseFailed)?;
- let addr = plugin_dir.get_address_for(&config.mqtt_plugin_name)?;
+ let addr = config.mqtt_plugin_name.build(plugin_dir)?;
Ok(MqttMeasurementBridgePlugin::new(addr, config.topic.clone()).finish())
}
}
@@ -83,7 +83,7 @@ where
#[derive(serde::Deserialize, Debug, tedge_api::Config)]
struct MqttMeasurementBridgeConfig {
/// The name of the mqtt plugin to send the measurements to
- mqtt_plugin_name: String,
+ mqtt_plugin_name: tedge_lib::config::Address,
/// The topic to send the measurements onto
topic: String,