aljaz/sphinx-key
1
1
Fork 0
mirror of https://github.com/stakwork/sphinx-key.git synced 2026-02-09 01:34:29 +01:00
Code Issues Packages Projects Releases Wiki Activity

immediate sub to hello and bye

Browse Source
This commit is contained in:
Evan Feenstra
2023-07-07 12:55:58 -07:00
parent b796cb902a
commit c8501fdd10
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
broker/src/mqtt.rs
View File

@@ -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 || {