I found a limitation in my diver which brings in data from an MQTT broker. 
If the publications arrive at a higher frequency than the weewx polling 
cycle, only the last one would get processed.

So I have added a queue which buffers incoming MQTT publications, which is 
then emptied in genLoopPackets.

See https://github.com/morrowwm/weewxMQTT

This should be portable to the forks which use different types of MQTT 
messages. 

wysiwyg (Frederic) recognized this issue some time ago: 
https://groups.google.com/d/msg/weewx-development/tNDnGNe9Z_M/7aBmfL5WAwAJ 
and I believe fixed it in his version.

Reply via email to