From c8501fdd10145ebbf4c93d156866bfde382240b3 Mon Sep 17 00:00:00 2001
From: Evan Feenstra <evanfeenstra@gmail.com>
Date: Fri, 7 Jul 2023 12:55:58 -0700
Subject: [PATCH] immediate sub to hello and bye

---
 broker/src/mqtt.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/broker/src/mqtt.rs b/broker/src/mqtt.rs
index cd8a6a5..637b068 100644
--- a/broker/src/mqtt.rs
+++ b/broker/src/mqtt.rs
@@ -28,7 +28,8 @@ pub fn start_broker(
 
     let (mut link_tx, mut link_rx) = broker.link("localclient")?;
 
-    link_tx.subscribe("#").unwrap();
+    link_tx.subscribe(format!("+/{}", topics::HELLO));
+    link_tx.subscribe(format!("+/{}", topics::BYE));
 
     let auth_sender_ = auth_sender.clone();
     std::thread::spawn(move || {