smqp

    4.0.0 • Public • Published

    SMQP

    Build StatusBuild statusCoverage StatusProject Status: Active – The project has reached a stable, usable state and is being actively developed.

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

    Install

    npm i smqp

    DownloadsWeekly Downloads

    399

    Version

    4.0.0

    License

    MIT

    Unpacked Size

    123 kB

    Total Files

    19

    Last publish

    Collaborators

    • avatar