From 9e35a0c1f373657e5e77c54765fd46f477f4e174 Mon Sep 17 00:00:00 2001 From: narawat lamaiin Date: Tue, 8 Oct 2024 13:22:19 +0700 Subject: [PATCH] update --- src/communication.jl | 3 ++- src/dbUtil.jl | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/communication.jl b/src/communication.jl index 57fcdd1..f58e2da 100644 --- a/src/communication.jl +++ b/src/communication.jl @@ -448,7 +448,7 @@ function checkMqttConnection!(mqttInstance::T; mqttConnStatus = isMqttConnectionAlive(mqttInstance) if mqttConnStatus == false isdisconnected = true - println("mqtt connection $mqttConnStatus, Attemping to reconnect") + println("mqtt connection $mqttConnStatus, Attemping to reconnect $(Dates.now())") # use new client to reconnect instead of the previous one because I don't want to modify MQTTClient.jl yet mqttInstance.client, mqttInstance.connection = MakeConnection(mqttInstance.mqttBrokerAddress, @@ -458,6 +458,7 @@ function checkMqttConnection!(mqttInstance::T; subscribe(mqttInstance.client, topic, mqttInstance.onMsgCallback, qos=mqttInstance.qos) end MQTTClient.subscribe(mqttInstance.client, mqttInstance.keepalivetopic, mqttInstance.onMsgCallback, qos=mqttInstance.qos) + sleep(30) else mqttInstance.lastTimeMqttConnCheck = Dates.now() if isdisconnected diff --git a/src/dbUtil.jl b/src/dbUtil.jl index 33f6fbd..40296bd 100644 --- a/src/dbUtil.jl +++ b/src/dbUtil.jl @@ -72,7 +72,8 @@ julia> insert_data = Dict( # Signature """ -function generateInsertSQL(table_name::String, columnToInsert::Vector{Symbol}, insert_data::Dict{Symbol, Any}) +function generateInsertSQL(table_name::String, columnToInsert::Vector{Symbol}, + insert_data::Dict{Symbol, Any}) columns = String[] values = String[]