diff --git a/src/CommUtils.jl b/src/CommUtils.jl index d4e1cb8..1c0790a 100644 --- a/src/CommUtils.jl +++ b/src/CommUtils.jl @@ -1,7 +1,7 @@ module CommUtils # request and respond cannot be exported because Genie confuse -export mqttClient, publish, request, respond +export mqttClient, publish, request, respond, mqttRun include("interface.jl") diff --git a/src/interface.jl b/src/interface.jl index 16ee00b..c5cee00 100644 --- a/src/interface.jl +++ b/src/interface.jl @@ -225,10 +225,10 @@ end """ function mqttSubOnConnect!(client::mqttClient) if client.connectStatus == true && client.subStatus == false - for (k, v) in pairs(client.sub) + for (k, v) in pairs(client.subtopic) if v != "" println("sub to $k") - subscribe(client.clientInstance, v) + Mosquitto.subscribe(client.clientInstance, v) client.subStatus = true end end