SMQP


Synchronous message queueing 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

- API

Usage

``javascript
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();
}
``