SMQP



Synchronous message queuing package. Used as an alternative - and frontend ready - event handler when you expect events to be handled in sequence.
Basically a synchronous amqp broker.
Documentation
Usage
import {Broker} from 'smqp';
const owner = {name: 'me'};
const broker = Broker(owner);
broker.subscribe('events', '#', 'event-queue', onMessage);
broker.publish('events', 'start', {arg: 1});
function onMessage(routingKey, message, brokerOwner) {
console.log('received:', routingKey);
console.log('with message:', message);
console.log('owned by:', brokerOwner.name);
message.ack();
}