summaryrefslogtreecommitdiffstats
path: root/crates/core/tedge_mapper/src/c8y/tests.rs
diff options
context:
space:
mode:
Diffstat (limited to 'crates/core/tedge_mapper/src/c8y/tests.rs')
-rw-r--r--crates/core/tedge_mapper/src/c8y/tests.rs9
1 files changed, 8 insertions, 1 deletions
diff --git a/crates/core/tedge_mapper/src/c8y/tests.rs b/crates/core/tedge_mapper/src/c8y/tests.rs
index 7cbed97a..04cf07cc 100644
--- a/crates/core/tedge_mapper/src/c8y/tests.rs
+++ b/crates/core/tedge_mapper/src/c8y/tests.rs
@@ -24,6 +24,7 @@ use tokio::task::JoinHandle;
use super::converter::{get_child_id_from_topic, CumulocityConverter};
const TEST_TIMEOUT_MS: Duration = Duration::from_millis(5000);
+const MQTT_HOST: &str = "127.0.0.1";
#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
#[serial]
@@ -796,7 +797,13 @@ impl C8YHttpProxy for FakeC8YHttpProxy {
async fn start_c8y_mapper(mqtt_port: u16) -> Result<JoinHandle<()>, anyhow::Error> {
let converter = create_c8y_converter();
- let mut mapper = create_mapper("c8y-mapper-test", mqtt_port, Box::new(converter)).await?;
+ let mut mapper = create_mapper(
+ "c8y-mapper-test",
+ MQTT_HOST.to_string(),
+ mqtt_port,
+ Box::new(converter),
+ )
+ .await?;
let mapper_task = tokio::spawn(async move {
let _ = mapper.run().await;