diff options
Diffstat (limited to 'crates/core/tedge_mapper/src/collectd/mapper.rs')
| -rw-r--r-- | crates/core/tedge_mapper/src/collectd/mapper.rs | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/crates/core/tedge_mapper/src/collectd/mapper.rs b/crates/core/tedge_mapper/src/collectd/mapper.rs index aac2b087..abae07af 100644 --- a/crates/core/tedge_mapper/src/collectd/mapper.rs +++ b/crates/core/tedge_mapper/src/collectd/mapper.rs @@ -3,7 +3,7 @@ use crate::{ core::component::TEdgeComponent, }; use async_trait::async_trait; -use tedge_config::{ConfigSettingAccessor, MqttPortSetting, TEdgeConfig}; +use tedge_config::{ConfigSettingAccessor, MqttBindAddressSetting, MqttPortSetting, TEdgeConfig}; use tracing::{info_span, Instrument}; const APP_NAME: &str = "tedge-mapper-collectd"; @@ -20,8 +20,11 @@ impl CollectdMapper { impl TEdgeComponent for CollectdMapper { async fn start(&self, tedge_config: TEdgeConfig) -> Result<(), anyhow::Error> { let mqtt_port = tedge_config.query(MqttPortSetting)?.into(); + let mqtt_host = tedge_config.query(MqttBindAddressSetting)?.to_string(); - let device_monitor_config = DeviceMonitorConfig::default().with_port(mqtt_port); + let device_monitor_config = DeviceMonitorConfig::default() + .with_port(mqtt_port) + .with_host(mqtt_host); let device_monitor = DeviceMonitor::new(device_monitor_config); device_monitor |