diff options
Diffstat (limited to 'crates/core/tedge_agent/src/agent.rs')
-rw-r--r-- | crates/core/tedge_agent/src/agent.rs | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/crates/core/tedge_agent/src/agent.rs b/crates/core/tedge_agent/src/agent.rs index d1285c22..aeabfc6a 100644 --- a/crates/core/tedge_agent/src/agent.rs +++ b/crates/core/tedge_agent/src/agent.rs @@ -17,8 +17,9 @@ use mqtt_channel::{Connection, Message, PubChannel, StreamExt, SubChannel, Topic use plugin_sm::plugin_manager::{ExternalPlugins, Plugins}; use std::{convert::TryInto, fmt::Debug, path::PathBuf, sync::Arc}; use tedge_config::{ - ConfigRepository, ConfigSettingAccessor, ConfigSettingAccessorStringExt, MqttPortSetting, - SoftwarePluginDefaultSetting, TEdgeConfigLocation, TmpPathDefaultSetting, + ConfigRepository, ConfigSettingAccessor, ConfigSettingAccessorStringExt, + MqttBindAddressSetting, MqttPortSetting, SoftwarePluginDefaultSetting, TEdgeConfigLocation, + TmpPathDefaultSetting, }; use tokio::sync::Mutex; use tracing::{debug, error, info, instrument}; @@ -107,6 +108,7 @@ impl SmAgentConfig { let tedge_config = config_repository.load()?; let mqtt_config = mqtt_channel::Config::default() + .with_host(tedge_config.query(MqttBindAddressSetting)?.to_string()) .with_port(tedge_config.query(MqttPortSetting)?.into()) .with_max_packet_size(10 * 1024 * 1024); |