fixup! fix: allow concurrent tedge connect <cloud> --test processes

Signed-off-by: Rina Fujino <[email protected]>

Author: rina23q

crates/common/mqtt_channel/src/config.rs

@@ -294,13 +294,14 @@ impl Config {
         }
     }
 
-    /// Set the random session name with prefix
+    /// Set the random session name with prefix and clear the session
     pub fn with_session_prefix(self, prefix: impl Into<String>) -> Self {
         let random: String = std::iter::repeat_with(fastrand::lowercase)
             .take(10)
             .collect();
         Self {
             session_name: Some(format!("{}-{}", prefix.into(), random)),
+            clean_session: true,
             ..self
         }
     }

crates/core/tedge/src/cli/connect/c8y.rs

@@ -200,7 +200,6 @@ pub(crate) async fn check_device_status_c8y(
     let mut mqtt_options = tedge_config
         .mqtt_config()?
         .with_session_prefix(CLIENT_ID)
-        .with_clean_session(true)
         .rumqttc_options()?;
 
     mqtt_options.set_keep_alive(RESPONSE_TIMEOUT);
@@ -324,7 +323,6 @@ pub(crate) async fn get_connected_c8y_url(
     let mut mqtt_options = tedge_config
         .mqtt_config()?
         .with_session_prefix(CLIENT_ID)
-        .with_clean_session(true)
         .rumqttc_options()?;
     mqtt_options.set_keep_alive(RESPONSE_TIMEOUT);