socket.io-emqx v1.0.8

Socket.io-emqx

A adapter for socket.io support using Emqx broker.

Homepage:

• https://www.emqx.io/
• https://socket.io/

Work fine on version emqx/emqx:v3.0.0

Install

$ npm install --save socket.io-emqx

Usage

const adapter = require('socket.io-emqx');
const MQTT_CONNECT = 'mqtt://emqx-worker:1883';


var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);

io.adapter(adapter(MQTT_CONNECT, {key: 'chat.socket.io', keepalive: 1, reconnectPeriod: 5000}));

Work fine for Docker Swarm Cluster

That's it!