From f767aee3dce4c537f8d5eda3b9535654c7accd4f Mon Sep 17 00:00:00 2001 From: Evan Feenstra Date: Wed, 31 Aug 2022 13:27:59 -0700 Subject: [PATCH] incoming topic --- sphinx-key/src/conn/mqtt.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/sphinx-key/src/conn/mqtt.rs b/sphinx-key/src/conn/mqtt.rs index e9b5ab1..97702fa 100644 --- a/sphinx-key/src/conn/mqtt.rs +++ b/sphinx-key/src/conn/mqtt.rs @@ -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"), }, },