An implementation of the bull npm library [https://github.com/OptimalBits/bull] backed by the AMQP protocol, compatible with RabbitMQ
NOTE: WORK IN PROGRESS - USE AT YOUR OWN RISK
Currently being used in production at whereto.com
Demo with RPC calling:
import Queue from 'bull-amqp'
const queue = new Queue(
'test',
process.env.AMQP_CONNECTION_STRING,
{
prefix: 'w2',
},
)
queue.process(1, async (job) => {
console.log('got job', job.data)
if (Math.random() > 0.9) { // to illustrate retrying
throw new Error('oops')
}
return {
hello: true,
...job.data,
}
})
queue.on('error', (err) => {
console.log('queue caught error', err)
})
setInterval(async () => {
console.log('response', await queue.call({ job: 'test' }))
}, 5000)BULL_AMQP_MIN_PROCESSING_TIME_MS - sets minimum processing time in milliseconds BULL_AMQP_CONCURRENCY - overrides concurrency value