diff --git a/crates/extensions/c8y_mapper_ext/src/actor.rs b/crates/extensions/c8y_mapper_ext/src/actor.rs index 4ecdc7ce0a1..ea1b39d1c96 100644 --- a/crates/extensions/c8y_mapper_ext/src/actor.rs +++ b/crates/extensions/c8y_mapper_ext/src/actor.rs @@ -181,6 +181,9 @@ impl C8yMapperActor { self.process_registration_message(pending_entity.reg_message) .await?; + // Wait for a while to allow the registration message to be processed by the cloud before sending the data messages + tokio::time::sleep(Duration::from_secs(1)).await; + // Convert and publish cached data messages for pending_data_message in pending_entity.data_messages { self.process_message(pending_data_message).await?;