update
This commit is contained in:
@@ -589,7 +589,6 @@ function sendReceiveMqttMsg(outgoingMsg::Dict{Symbol, T};
|
|||||||
put!(mqttMsgReceiveChannel[:ch1], incomingMqttMsg)
|
put!(mqttMsgReceiveChannel[:ch1], incomingMqttMsg)
|
||||||
elseif occursin("keepalive", topic)
|
elseif occursin("keepalive", topic)
|
||||||
put!(keepaliveChannel, incomingMqttMsg)
|
put!(keepaliveChannel, incomingMqttMsg)
|
||||||
println("keepalive received ", incomingMqttMsg)
|
|
||||||
else
|
else
|
||||||
println("undefined condition ", @__FILE__, " ", @__LINE__)
|
println("undefined condition ", @__FILE__, " ", @__LINE__)
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user