fixup! Lock free entity store

thin-edge · Jan 10, 2025 · b10eca6 · b10eca6
1 parent fb370bf
commit b10eca6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/crates/core/tedge_agent/src/agent.rs b/crates/core/tedge_agent/src/agent.rs
@@ -393,7 +393,7 @@ impl Agent {
             let mut entity_store_actor_builder =
                 ServerActorBuilder::new(entity_store_server, &ServerConfig::default(), Sequential);
             mqtt_actor_builder.connect_mapped_sink(
-                entity_manager::server::subscriptions(),
+                entity_manager::server::subscriptions(self.config.mqtt_topic_root.as_ref()),
                 &entity_store_actor_builder,
                 |message| {
                     Some(RequestEnvelope {

diff --git a/crates/core/tedge_agent/src/entity_manager/server.rs b/crates/core/tedge_agent/src/entity_manager/server.rs
@@ -181,6 +181,7 @@ impl EntityStoreServer {
     }
 }
 
-pub fn subscriptions() -> TopicFilter {
-    vec!["te/+/+/+/+/#"].try_into().unwrap()
+pub fn subscriptions(topic_root: &str) -> TopicFilter {
+    let topic = format!("{}/+/+/+/+/#", topic_root);
+    vec![topic].try_into().unwrap()
 }