ton/GeneralUtils
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
narawat lamaiin
2025-01-25 13:31:15 +07:00
parent 2700e594e4
commit 43ead8b8d5
2 changed files with 45 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/communication.jl
View File

@@ -496,7 +496,7 @@ function sendMqttMsg(outgoingMsg::Dict{Symbol, T})::NamedTuple where {T<:Any}
)
response = sendMqttMsg(mqttInstance, outgoingMsg)
disconnect(mqttInstance.client)
try disconnect(mqttInstance.client) catch end
return response
end
@@ -576,7 +576,7 @@ function sendReceiveMqttMsg(outgoingMsg::Dict{Symbol, T};
)
response = sendReceiveMqttMsg(mqttInstance, :ch1, outgoingMsg; timeout=timeout, maxattempt=maxattempt)
disconnect(mqttInstance.client)
try disconnect(mqttInstance.client) catch end
return response
end