update
This commit is contained in:
@@ -80,6 +80,7 @@ mutable struct mqttClientInstance_v2 <: mqttClientInstance
|
|||||||
keepaliveCheckInterval::Integer # second
|
keepaliveCheckInterval::Integer # second
|
||||||
lastTimeMqttConnCheck::Union{DateTime, Nothing}
|
lastTimeMqttConnCheck::Union{DateTime, Nothing}
|
||||||
multiMsg::String # "single", "metadata", "datapart"
|
multiMsg::String # "single", "metadata", "datapart"
|
||||||
|
latestMsg
|
||||||
end
|
end
|
||||||
""" MQTT client v2. The difference between client v1 and v2 is v2 allows multiple
|
""" MQTT client v2. The difference between client v1 and v2 is v2 allows multiple
|
||||||
msgReceiveChannel without having to redefine mqttClientInstance again like in v1.
|
msgReceiveChannel without having to redefine mqttClientInstance again like in v1.
|
||||||
@@ -178,6 +179,7 @@ function mqttClientInstance_v2(
|
|||||||
keepaliveCheckInterval,
|
keepaliveCheckInterval,
|
||||||
nothing,
|
nothing,
|
||||||
multiMsg,
|
multiMsg,
|
||||||
|
nothing, # store latest message to prevent doing the same massage twice
|
||||||
)
|
)
|
||||||
|
|
||||||
return instance
|
return instance
|
||||||
|
|||||||
Reference in New Issue
Block a user