From 5a89e86120a6e4304061f72553e8e2a7d09f039a Mon Sep 17 00:00:00 2001 From: narawat lamaiin Date: Tue, 3 Jun 2025 10:08:40 +0700 Subject: [PATCH] update --- src/communication.jl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/communication.jl b/src/communication.jl index 18acde8..31c6852 100644 --- a/src/communication.jl +++ b/src/communication.jl @@ -393,7 +393,7 @@ end ----- mqttInstanceDict::Dict{Symbol, Any} a dictionary contain mqtt instance. 1 per mqtt client. - interval::Integer + keepaliveCheckInterval::Integer time interval to check mqtt server in seconds Return\n @@ -629,6 +629,7 @@ function sendReceiveMqttMsg(mqttInstance::mqttClientInstance_v2, receivechannel: println("\n attempts $attempts/$maxattempt ", @__FILE__, ":", @__LINE__, " $(Dates.now())") pprintln(outgoingMsg) println(" attempts $attempts/$maxattempt ", @__FILE__, ":", @__LINE__, " $(Dates.now())\n") + checkMqttConnection!(mqttInstance, keepaliveCheckInterval=5) end attempts += 1 end