diff options
author | PradeepKiruvale <pradeepkumar.kj@softwareag.com> | 2022-03-01 09:41:29 +0530 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-03-01 09:41:29 +0530 |
commit | 6a1f0d72c384b4e647711f483eba992b8095b6f4 (patch) | |
tree | b7531e80c61dc13b2fa38949309aa64dc068e0ff /crates/core/tedge_mapper/src/az/mapper.rs | |
parent | 3e52543e1d63a333098eba46361d80218dbd6868 (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.rs | 5 |
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() |