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

incoming topic

Browse Source
This commit is contained in:
Evan Feenstra
2022-08-31 13:27:59 -07:00
parent d98af6d7e0
commit f767aee3dc
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
sphinx-key/src/conn/mqtt.rs
View File

@@ -78,9 +78,11 @@ pub fn start_listening(
Event::Subscribed(_mes_id) => info!("RECEIVED Subscribed MESSAGE"),
Event::Unsubscribed(_mes_id) => info!("RECEIVED Unsubscribed MESSAGE"),
Event::Published(_mes_id) => info!("RECEIVED Published MESSAGE"),
Event::Received(msg) => tx
.send(CoreEvent::VlsMessage(msg.data().to_vec()))
.expect("couldnt send Event::Message"),
Event::Received(msg) => {
let _topic = msg.topic();
tx.send(CoreEvent::VlsMessage(msg.data().to_vec()))
.expect("couldnt send Event::Message");
}
Event::Deleted(_mes_id) => info!("RECEIVED Deleted MESSAGE"),
},
},