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
2024-10-08 13:22:19 +07:00
parent b8d6796920
commit 9e35a0c1f3
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/communication.jl
View File

@@ -448,7 +448,7 @@ function checkMqttConnection!(mqttInstance::T;
mqttConnStatus = isMqttConnectionAlive(mqttInstance) mqttConnStatus = isMqttConnectionAlive(mqttInstance)
if mqttConnStatus == false if mqttConnStatus == false
isdisconnected = true 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 # use new client to reconnect instead of the previous one because I don't want to modify MQTTClient.jl yet
mqttInstance.client, mqttInstance.connection = mqttInstance.client, mqttInstance.connection =
MakeConnection(mqttInstance.mqttBrokerAddress, MakeConnection(mqttInstance.mqttBrokerAddress,
@@ -458,6 +458,7 @@ function checkMqttConnection!(mqttInstance::T;
subscribe(mqttInstance.client, topic, mqttInstance.onMsgCallback, qos=mqttInstance.qos) subscribe(mqttInstance.client, topic, mqttInstance.onMsgCallback, qos=mqttInstance.qos)
end end
MQTTClient.subscribe(mqttInstance.client, mqttInstance.keepalivetopic, mqttInstance.onMsgCallback, qos=mqttInstance.qos) MQTTClient.subscribe(mqttInstance.client, mqttInstance.keepalivetopic, mqttInstance.onMsgCallback, qos=mqttInstance.qos)
sleep(30)
else else
mqttInstance.lastTimeMqttConnCheck = Dates.now() mqttInstance.lastTimeMqttConnCheck = Dates.now()
if isdisconnected if isdisconnected

3
src/dbUtil.jl
View File

@@ -72,7 +72,8 @@ julia> insert_data = Dict(
# Signature # 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[] columns = String[]
values = String[] values = String[]