mqu's Introduction

mqu

npm i mqu

Example

const mqu = require('mqu')('amqp://guest:guest@localhost:5672')

mqu.on('error', error => {
  console.error('oh my, error!!', error)
  process.kill(process.pid)
})

mqu.on('connect',  () => {
  console.error('connect method succeeded')
})

mqu.consumeJob('j', data => console.log('worker 1', data))
mqu.consumeJob('j', data => console.log('worker 2', data))

mqu.consumeEvent('e', data => console.log('\thandler 1', data))
mqu.consumeEvent('e', data => console.log('\thandler 2', data))
mqu.consumeEvent('e', data => console.log('\thandler 3', data))

const jobInterval = setInterval(() => {
  const job = new Date().toISOString() + '-job'
  mqu.publishJob('j', job).then(() => console.log('published job', job))
}, 2000)

const eventInterval = setInterval(() => {
  const ev = new Date().toISOString() + '-event'
  mqu.publishEvent('e', ev).then(() => console.log('published event', ev))
}, 1500)

process.on('SIGINT', () => {
  clearInterval(jobInterval)
  clearInterval(eventInterval)
  mqu.close().then(() => console.log('closed!'))
})

Events

error - emitted when transport, protocol or consumer error is occurred
connect - emitted when a protocol level connection is ready

Why?

Because best RabbitMQ client for node.js bramqp is too verbose to be used directly for:

round robin distribution of jobs between workers
fanout distribution of events to listeners

License

MIT

mqu's People

Contributors

Stargazers

Watchers

mqu's Issues

.publishJob error doesn't get caught in catch block

Code sample to reproduce

// I intentionally changed port 5672 -> 5673 to get an error
const mqu = require('mqu')('amqp://guest:guest@localhost:5673')

async function main () {
	try {
		await mqu.publishJob('job', { kappa: 'lul' })
	} catch (error) {
		// Doesn't catch
		console.error('Caught', error)
	}
}

main()

// Doesn't catch
process.on('unhandledRejection', (error) => console.error('Unhandled', error))
// Caught here :thinking_face:
process.on('uncaughtException', (error) => console.error('Uncaught', error))

option to defer connection

queue calls and bind to rmq object when connected

add aliases: consume->subscribe, something else?

Cannot connect to amqps://... URL

I'm trying to connect to a rabbitmq server hosted on compose.io
It's not possible for me to get a connection at this moment. Do you have an idea?
maybe there's some info in amqp-node/amqplib#331
Thank you! :)

Recommend Projects