summaryrefslogtreecommitdiffstats
path: root/crates/core/tedge_mapper/src/az/mapper.rs
diff options
context:
space:
mode:
authorPradeepKiruvale <pradeepkumar.kj@softwareag.com>2022-03-01 09:41:29 +0530
committerGitHub <noreply@github.com>2022-03-01 09:41:29 +0530
commit6a1f0d72c384b4e647711f483eba992b8095b6f4 (patch)
treeb7531e80c61dc13b2fa38949309aa64dc068e0ff /crates/core/tedge_mapper/src/az/mapper.rs
parent3e52543e1d63a333098eba46361d80218dbd6868 (diff)
[823] Configurable mqtt bind address (#929)
* [823] add mqtt.bind_address option * ipaddress instead of string
Diffstat (limited to 'crates/core/tedge_mapper/src/az/mapper.rs')
-rw-r--r--crates/core/tedge_mapper/src/az/mapper.rs5
1 files changed, 3 insertions, 2 deletions
diff --git a/crates/core/tedge_mapper/src/az/mapper.rs b/crates/core/tedge_mapper/src/az/mapper.rs
index e9c0b7ee..542e6c1c 100644
--- a/crates/core/tedge_mapper/src/az/mapper.rs
+++ b/crates/core/tedge_mapper/src/az/mapper.rs
@@ -5,7 +5,7 @@ use crate::{
use async_trait::async_trait;
use clock::WallClock;
-use tedge_config::{AzureMapperTimestamp, TEdgeConfig};
+use tedge_config::{AzureMapperTimestamp, MqttBindAddressSetting, TEdgeConfig};
use tedge_config::{ConfigSettingAccessor, MqttPortSetting};
use tracing::{info_span, Instrument};
@@ -24,12 +24,13 @@ impl TEdgeComponent for AzureMapper {
async fn start(&self, tedge_config: TEdgeConfig) -> Result<(), anyhow::Error> {
let add_timestamp = tedge_config.query(AzureMapperTimestamp)?.is_set();
let mqtt_port = tedge_config.query(MqttPortSetting)?.into();
+ let mqtt_host = tedge_config.query(MqttBindAddressSetting)?.to_string();
let clock = Box::new(WallClock);
let size_threshold = SizeThreshold(255 * 1024);
let converter = Box::new(AzureConverter::new(add_timestamp, clock, size_threshold));
- let mut mapper = create_mapper(AZURE_MAPPER_NAME, mqtt_port, converter).await?;
+ let mut mapper = create_mapper(AZURE_MAPPER_NAME, mqtt_host, mqtt_port, converter).await?;
mapper
.run()