@mysetup/mqtt

MQTT helpers for creating connections, subscribing, publishing, and reusing clients.

Installation

pnpm add @mysetup/mqtt

Supported libraries and runtimes

| Supported | Notes | | ---------------------- | ------------------------------- | | Node.js | Full support | | Next.js server runtime | Supported in backend-only usage | | Browser apps | Not supported |

Usage

import {
    mqttCreateConnection,
    mqttDisconnect,
    mqttPublish,
    mqttSub,
} from "@mysetup/mqtt";

const clientId = "app-client";
const config = {
    protocol: "mqtt",
    host: "localhost",
    port: 1883,
    path: "",
};

mqttCreateConnection({
    clientId,
    config,
    topicList: ["updates/topic"],
    messageCallback: (topic, payload) => {
        console.log(topic, payload);
    },
    environment: "development",
});

mqttSub(["updates/topic"], clientId);
mqttPublish("updates/topic", { hello: "world" }, clientId);
mqttDisconnect(
    {
        clientId,
        config,
        topicList: ["updates/topic"],
        messageCallback: () => {},
    },
    false,
);

Exports

• mqttCreateConnection
• mqttSub
• mqttUnSub
• mqttPublish
• mqttDisconnect
• getMqttClient
• removeMqttClient