Mojo-plugin-mqtt-helper NPM

A mojo.js plugin to add an MQTT helper, wrapped over async-mqtt module.

API

The API is the same as async-mqtt client.

Example

import mojo from '@mojojs/core';
import mqttPlugin from 'mojo-plugin-mqtt-helper';

const app = mojo();
app.plugin(mqttPlugin);

app.get('/', async ctx => {
  const client = await ctx.mqttClient('mqtt://test.mosquitto.org');
  client.on('message', async (topic, message) => {
    await ctx.render({text: `Received message on topic ${topic}: ${message}`});
    await client.end();
  });
  await client.subscribe('mojojs/test/#');
  await client.publish('mojojs/test/hello/Channel', 'Hello world!');
});
app.start();