Rabbit-PubSub

amqplib wrapper for easier rabbitmq scripting of pub/sub model

Install

npm install @modulus/rabbit-pubsub

Usage

RabbitPubSub(url, [options])

The exported function takes the same parameters as amqplib.connect, and returns a object with two exported functions, publish and subscribe.

Publish(exchange, message, done)

Sends data to subscribers and yields.

const PubSub = require('@modulus/rabbit-rpc')(url)

PubSub.publish('tasks', { message: true }, (err, result) => {
  if (err) throw err // unable to publish

  console.log('message delivered')
})

Subscribe(exchange, worker)

Consumes messages on subscribed topics and passes them to worker. When worker calls done acknowledges the message and sends the result to the client.

const PubSub = require('@modulus/rabbit-rpc')(url)

PubSub.subscribe('tasks', (msg, done) => {
  // do work
  done(null, { result: true })
})

Contribute

Contributions welcome! Please read the contributing guidelines first.