update
This commit is contained in:
@@ -611,6 +611,9 @@ julia> outgoingMsg = Dict(
|
||||
julia> success, error, response = GeneralUtils.sendReceiveMqttMsg(outgoingMsg)
|
||||
```
|
||||
|
||||
# TODO
|
||||
- [] update docs
|
||||
|
||||
# Signature
|
||||
"""
|
||||
function sendReceiveMqttMsg(outgoingMsg::Dict{Symbol, T};
|
||||
@@ -649,6 +652,10 @@ function sendReceiveMqttMsg(mqttInstance::mqttClientInstance_v2, receivechannel:
|
||||
timepass = nothing
|
||||
attempts = 1
|
||||
while attempts <= maxattempt
|
||||
if attempts > 1
|
||||
println("attempts $attempts ", @__FILE__, " ", @__LINE__)
|
||||
end
|
||||
|
||||
sendMqttMsg(mqttInstance, outgoingMsg)
|
||||
|
||||
starttime = Dates.now()
|
||||
@@ -673,7 +680,7 @@ function sendReceiveMqttMsg(mqttInstance::mqttClientInstance_v2, receivechannel:
|
||||
end
|
||||
sleep(1)
|
||||
end
|
||||
println("attempts $attempts ", @__FILE__, " ", @__LINE__)
|
||||
|
||||
attempts += 1
|
||||
end
|
||||
|
||||
|
||||
Reference in New Issue
Block a user