diff options
author | Didier Wenzek <didier.wenzek@acidalie.com> | 2022-01-07 12:02:41 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-01-07 12:02:41 +0000 |
commit | a33a155dc458ad038db9f46f7751f8b34a6e9144 (patch) | |
tree | 2e9e4547c9961787e3680fa1abd3d19a1a503e31 /crates/core/tedge_agent/src/agent.rs | |
parent | a8539884e7cb0f84ea2973f53ddd8fc2dd3b360b (diff) |
Remove capabilities messages on tedge agent start (#741)
Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>
Co-authored-by: Didier Wenzek <didier.wenzek@free.fr>
Diffstat (limited to 'crates/core/tedge_agent/src/agent.rs')
-rw-r--r-- | crates/core/tedge_agent/src/agent.rs | 12 |
1 files changed, 0 insertions, 12 deletions
diff --git a/crates/core/tedge_agent/src/agent.rs b/crates/core/tedge_agent/src/agent.rs index 3764523a..b915d748 100644 --- a/crates/core/tedge_agent/src/agent.rs +++ b/crates/core/tedge_agent/src/agent.rs @@ -195,8 +195,6 @@ impl SmAgent { let () = self.process_pending_operation(&mqtt).await?; - // * Maybe it would be nice if mapper/registry responds - let () = publish_capabilities(&mqtt).await?; while let Err(error) = self .process_subscribed_messages(&mqtt, &mut operations, &plugins) .await @@ -526,16 +524,6 @@ fn get_default_plugin( Ok(tedge_config.query_string_optional(SoftwarePluginDefaultSetting)?) } -async fn publish_capabilities(mqtt: &Client) -> Result<(), AgentError> { - mqtt.publish(Message::new(&Topic::new("tedge/capabilities/software/list")?, "").retain()) - .await?; - - mqtt.publish(Message::new(&Topic::new("tedge/capabilities/software/update")?, "").retain()) - .await?; - - Ok(()) -} - #[cfg(test)] mod tests { use super::*; |