fix: client id with tenant prefix should be set globally (#564)

bytebeamio · Feb 1, 2023 · 039d9eb · 039d9eb
1 parent 1b1e83f
commit 039d9eb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/rumqttd/src/link/local.rs b/rumqttd/src/link/local.rs
@@ -58,8 +58,8 @@ impl Link {
             last_will,
             dynamic_filters,
         );
-        let incoming = Incoming::new(client_id.to_string());
-        let (outgoing, link_rx) = Outgoing::new(client_id.to_string());
+        let incoming = Incoming::new(connection.client_id.to_owned());
+        let (outgoing, link_rx) = Outgoing::new(connection.client_id.to_owned());
         let outgoing_data_buffer = outgoing.buffer();
         let incoming_data_buffer = incoming.buffer();