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.
