Docs

ZeroMqttPump

ZeroMqttPump handles bounded MQTT publish draining so message work does not collapse back into ad-hoc loops. Use it when publish cadence and reconnect pressure need structure.

Why this page matters

This page explains how ZeroMqttPump fits into the wider ZeroKernel execution model, what problem it is meant to solve, and what trade-off you are actually accepting when you use it in production firmware. The goal is not to treat ZeroMqttPump as an isolated API call, but to understand where it sits inside bounded scheduling, queue discipline, fault visibility, and profile selection.

Read this topic as an operational contract. Start from the smallest working path, wire it into a lean profile first, and only expand into richer routing, diagnostics, or transport state after you can prove that the timing outcome is still worth the extra flash and RAM. That mindset is what keeps ZeroKernel useful on small boards instead of turning it into another bloated abstraction.

The safest pattern is always the same: define the runtime boundary, keep the hot path short, measure the effect with compare scripts, and only then scale complexity. The examples below are not filler; they show the smallest repeatable patterns you can lift into real firmware when you need clean integration instead of ad-hoc loops.

Three practical patterns

WiFi maintenance loop

Keep reconnect pacing separate from sensor cadence so link churn does not poison the hot path.

C++
    ZeroWiFiMaintainer wifi;
wifi.setBackoff(250, 2000);
wifi.tick(linkIsUp, attemptReconnect);
  
HTTP queue step pump

Queue the work first, then drain it cooperatively instead of letting one POST dominate the loop.

C++
    ZeroHttpPump pump;
pump.enqueue(payload);
pump.tick(connectStep, writeStep, finishStep);
  
MQTT publish drain

Bound publish attempts per tick and read the success rate next to queue depth, not in isolation.

C++
    ZeroMqttPump mqtt;
mqtt.enqueue(topicKey, value);
mqtt.tick(connectBroker, publishStep);
  

What to verify while you use it

  • Validate timing before you validate aesthetics. A cleaner API is not a win if fast misses rise.
  • Prefer the smallest profile that still matches the workload, then add optional modules only when the measured payoff is obvious.
  • Keep callbacks and transport steps bounded so watchdog, panic flow, and queue limits remain meaningful.

Common mistakes that make results misleading

  • Do not copy a demo pattern into production firmware without measuring it on the real board and real build profile you plan to ship.
  • Do not read success counters without reading queue depth, timing, and workload label next to them.
  • Do not enable heavier diagnostics and compatibility flags in a lean target just because the defaults looked convenient.

Recommended working sequence

Start from the smallest valid path

Boot the runtime, register the minimum useful task set, and prove that the baseline timing is clean before adding optional layers.

Add one layer, then measure it

Introduce routing, diagnostics, or transport one layer at a time so the cost and payoff remain obvious.

Publish only repeatable results

Update docs, charts, or public claims only after the same workload survives the same validation path more than once.

Main role

The module keeps publish work in a queue, drains it with explicit limits, and makes retry behavior visible in the same way HTTP pumping does.

Best use cases

  • Telemetry nodes with a steady publish cadence
  • Devices that need bounded queue behavior during reconnect churn
  • Projects where manual MQTT loops are already becoming hard to reason about

ZeroMqttPump FAQ

Does it replace your broker client library?

No. It wraps and organizes the device-side publishing pattern; it does not replace the broker client itself.

What is the safest way to validate this page on real hardware?

Start from the leanest profile that still matches the topic, run the narrowest compare script for this behavior, and only then move to heavier mixed workloads. Do not jump straight to a fully loaded build if the base timing is not yet proven.

When should I stop adding abstraction around this topic?

Stop when the extra layer no longer produces a measurable payoff. If RAM, flash, or execution cost rises while misses, throughput, or recovery do not improve, you are paying complexity without getting runtime value back.