@steelbreeze/broker

broker

Lightweight publish and subscribe using Server-Sent Events for node and express

If you like broker, please star it...

Install

npm i @steelbreeze/broker

Usage

Server

To create a message broker server within an express application:

const express = require('express');
const broker = require('@steelbreeze/broker');

// create the express application
var app = express();

// create a message broker server and bind it to the /events base URL
app.use('/events', broker.server({lastMessage: true}));

// start the express application
app.listen(1024, 'localhost');

You can create multiple message broker servers and bind them to different base URLs.

Subscriber

To create a subscription:

const broker = require('@steelbreeze/broker');

// create a client to the message broker
var client = broker.client({host:'localhost', port: 1024, path: '/events'});

// subscribe to the devices topic on the /events broker
client.subscribe('devices', (message) => {
	console.log(`devices: ${message}`);
});
A single client can subscribe to multiple topics.

Publisher

To create a subscription:

const broker = require('@steelbreeze/broker');

// create a client to the message broker
var client = broker.client({host:'localhost', port: 1024, path: '/events'});

// publish a message on the devices topic of the /events broker every second
setInterval( () => {
	client.publish('devices', `Hello devices at ${new Date()}`);
}, 1000);

License

MIT License

Copyright (c) 2018 David Mesquita-Morris