diff options
author | Matthias Beyer <matthias.beyer@ifm.com> | 2022-05-18 15:21:29 +0200 |
---|---|---|
committer | Matthias Beyer <matthias.beyer@ifm.com> | 2022-05-23 12:17:59 +0200 |
commit | 7d1e1be2004eabd74422f1ac1829fdfe964e9ae1 (patch) | |
tree | a0bca94476811abd8f52779145e5631d253089ba | |
parent | 8cfce62c8dfaaf2986aa122bc80ac465b1e46b55 (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.rs | 4 |
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, |