fastify-async-mqtt

Fastify Async Mqtt is wrapper over async-mqtt with TypeScript support.

Install

npm i fastify-async-mqtt

Usage

Add it to your project with register and you are done!

1import fastify from 'fastify'
2import { fastifyMQTT } from './mqtt-module'
3
4const server = fastify()
5
6// register plugin 
7server.register(fastifyMQTT, { url: 'mqtt://localhost:1883' })
8
9server.register(async function (instance) { 
10    if (!instance.mqttClient) return
11    await instance.mqttClient.publish("hello/world", "Hi Mosquitto");
12  })
13
14server.listen({ port: 3000, host: '0.0.0.0' }, err => {
15  if (err) throw err
16})

or usage on request

1// another type of register
2server.register(fastifyMQTT, { 
3        opts: {host: 'mosquitto', port: 1883, protocol: 'mqtt'}, 
4        allowRetries: false 
5    })
6
7server.get('/ping/mqtt', async function (req, reply) {
8    await this.mqttClient.publish("hello/world", "Hi Mosquitto");
9    reply.send({mqtt: 'pinged'})
10})
11

License

Licensed under MIT.