update
This commit is contained in:
@@ -191,7 +191,7 @@ function mqttClientInstance_v2(
|
|||||||
while isready(msgReceiveChannel[i])
|
while isready(msgReceiveChannel[i])
|
||||||
_ = take!(msgReceiveChannel[i])
|
_ = take!(msgReceiveChannel[i])
|
||||||
end
|
end
|
||||||
println("Total $totalmsg old MQTT messages cleared", @__FILE__, ":", @__LINE__, " $(Dates.now())")
|
println("Total $totalmsg old MQTT messages cleared ", @__FILE__, ":", @__LINE__, " $(Dates.now())")
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user