amalgame-mqtt

Overview

Pure-AM implementation of the MQTT 3.1.1 protocol over raw TCP. Ideal for IoT and telemetry pipelines: broker-compatible with Mosquitto, HiveMQ, EMQX, AWS IoT Core.

Features

• ✓Pure MQTT 3.1.1 protocol (CONNECT / SUBSCRIBE / PUBLISH / PINGREQ)
• ✓QoS 0 (fire-and-forget) in v1 — QoS 1/2 planned
• ✓Wildcards + and # in topics
• ✓Retained and will messages
• ✓Optional TLS via amalgame-tls

Example

Minimal usage example — copy-paste runnable after install.

amc package add mqtt

let c = MqttClient.Connect("tcp://broker:1883", "client-42")
c.Subscribe("sensors/+/temp")
c.OnMessage(fn(topic, payload) {
    Console.WriteLine(topic + " → " + payload)
})
c.Publish("sensors/room1/temp", "21.5")

Related packages