chumicro-mqtt¶

Non-blocking MQTT 3.1.1 client (QoS 0 + 1) for CircuitPython, MicroPython, and CPython.

Built on chumicro-sockets and chumicro-timing — your LED keeps blinking through CONNECT, SUBSCRIBE, PUBLISH, and PUBACK round-trips because every step takes one tick of work.

Quick example¶

from chumicro_timing import ticks_ms
from chumicro_mqtt import MQTTClient

# On CircuitPython pass radio=wifi.radio; MP / CPython have no radio.
# from_config builds the transport factory: the client dials the broker
# non-blocking (one connect phase per tick) and self-heals after drops.
client = MQTTClient.from_config(
    {"mqtt.broker.host": "broker.example.com", "mqtt.broker.port": 1883},
)

client.on_message = lambda topic, payload: print(topic, payload)
client.connect()

# Drive from your tick loop — runner-shaped.
while True:
    now = ticks_ms()
    if client.check(now):
        client.handle(now)

Documentation¶

User Guide — connecting, QoS 1, last-will, TLS, pattern routing, tuning knobs
API Reference — full API documentation
Testing Helpers — fakes for downstream test suites