fix(shadow): Remove unused tenant_id field

bytebeamio · Oct 1, 2022 · 0d9c924 · 0d9c924
1 parent 5b976d3
commit 0d9c924
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 10 deletions.
diff --git a/rumqttd/src/link/console.rs b/rumqttd/src/link/console.rs
@@ -15,7 +15,8 @@ impl ConsoleLink {
     /// Requires the corresponding Router to be running to complete
     pub fn new(config: ConsoleSettings, router_tx: Sender<(ConnectionId, Event)>) -> ConsoleLink {
         let tx = router_tx.clone();
-        let (link_tx, link_rx, _ack) = Link::new(/*None,*/ "console", tx, true, None, true).unwrap();
+        let (link_tx, link_rx, _ack) =
+            Link::new(/*None,*/ "console", tx, true, None, true).unwrap();
         let connection_id = link_tx.connection_id;
         ConsoleLink {
             config,

diff --git a/rumqttd/src/link/shadow.rs b/rumqttd/src/link/shadow.rs
@@ -71,14 +71,8 @@ impl ShadowLink {
         let subscriptions = HashSet::new();
         let client_id = connect.client_id.clone();
 
-        let (link_tx, link_rx, _ack) = Link::new(
-            None,
-            &client_id,
-            router_tx,
-            true,
-            None,
-            config.dynamic_filters,
-        )?;
+        let (link_tx, link_rx, _ack) =
+            Link::new(&client_id, router_tx, true, None, config.dynamic_filters)?;
         let connection_id = link_rx.id();
 
         // Send connection acknowledgement back to the client

diff --git a/rumqttd/src/server/broker.rs b/rumqttd/src/server/broker.rs
@@ -262,7 +262,7 @@ impl<P: Protocol + Clone + Send + 'static> Server<P> {
             None => Ok(/*(*/ Box::new(stream) /*, None)*/),
         }
         #[cfg(not(any(feature = "use-rustls", feature = "use-native-tls")))]
-        Ok(/*(*/Box::new(stream)/*, None)*/)
+        Ok(/*(*/ Box::new(stream) /*, None)*/)
     }
 
     async fn start(&self, shadow: bool) -> Result<(), Error> {