@koyfin/message-bus v1.5.1

message-bus

Abstraction layer for message bus with pub-sub and RPC patterns implemented

pub-sub example

const {Bus, Events} = require('message-bus')

const key = 'somekey'
const url = 'amqp://localhost'

Bus.connect(url)
.then((bus) => {
  const publisher = bus.publisher(key)
  const subscriber = bus.subscriber(key)

  subscriber
    .on(Events.MESSAGE, (msg, content) => {
      // console.log(msg) // raw message
      console.log(content) // parsed message content
      bus.ack(msg)
    })
    .on(Events.ERROR, (error, msg) => {
      console.error(error)
      bus.nack(msg, allUpTo, requeue) // bus.ack(msg)
    })
      
    subscriber.subscribe()
    .then(() => {
      setInterval(() => publisher.publish({any: 'object'}), 2000)
    })
})

bus configuration

bus.configure((channel) => {
  // channel is an instance of amqplib.Channel
  return Promise.resolve()
})