From cf7065a6f5234ff1400581dd56eb04bf01d7be38 Mon Sep 17 00:00:00 2001
From: ton <narawat@gmail.com>
Date: Fri, 6 Oct 2023 20:27:32 +0700
Subject: [PATCH] mqttOnmessage! now return topic

---
 src/interface.jl | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/interface.jl b/src/interface.jl
index cf57757..bf07c99 100644
--- a/src/interface.jl
+++ b/src/interface.jl
@@ -277,11 +277,10 @@ function mqttOnmessage!(client::mqttClient)
     else
         for i = 1:nmessages
             pkg = take!(get_messages_channel()) # take new arrival package
-            topic = pkg.topic
             # sptoptic = split(topic, "/")
             payload = vecToDict(pkg.payload)    # payload in Dict format
             
-            return payload
+            return pkg.topic, payload
         end
     end
 end