update
This commit is contained in:
@@ -441,7 +441,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(1) # wait before checking connection again
|
||||
sleep(10) # wait before check connection again
|
||||
else
|
||||
mqttInstance.lastTimeMqttConnCheck = Dates.now()
|
||||
if isreconnect
|
||||
|
||||
Reference in New Issue
Block a user