update
This commit is contained in:
@@ -393,7 +393,7 @@ end
|
|||||||
-----
|
-----
|
||||||
mqttInstanceDict::Dict{Symbol, Any}
|
mqttInstanceDict::Dict{Symbol, Any}
|
||||||
a dictionary contain mqtt instance. 1 per mqtt client.
|
a dictionary contain mqtt instance. 1 per mqtt client.
|
||||||
interval::Integer
|
keepaliveCheckInterval::Integer
|
||||||
time interval to check mqtt server in seconds
|
time interval to check mqtt server in seconds
|
||||||
|
|
||||||
Return\n
|
Return\n
|
||||||
@@ -629,6 +629,7 @@ function sendReceiveMqttMsg(mqttInstance::mqttClientInstance_v2, receivechannel:
|
|||||||
println("\n<sendReceiveMqttMsg()> attempts $attempts/$maxattempt ", @__FILE__, ":", @__LINE__, " $(Dates.now())")
|
println("\n<sendReceiveMqttMsg()> attempts $attempts/$maxattempt ", @__FILE__, ":", @__LINE__, " $(Dates.now())")
|
||||||
pprintln(outgoingMsg)
|
pprintln(outgoingMsg)
|
||||||
println("</sendReceiveMqttMsg()> attempts $attempts/$maxattempt ", @__FILE__, ":", @__LINE__, " $(Dates.now())\n")
|
println("</sendReceiveMqttMsg()> attempts $attempts/$maxattempt ", @__FILE__, ":", @__LINE__, " $(Dates.now())\n")
|
||||||
|
checkMqttConnection!(mqttInstance, keepaliveCheckInterval=5)
|
||||||
end
|
end
|
||||||
attempts += 1
|
attempts += 1
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user