@workerhive/mq v2.1.16

Workhub Message Queue

Message queue library for workhub

Functions

• Add message to queue
• Watch queue for job result items
• Get pressure on queue

MQ.getQueuePressure('queue').then(pressure => {
    pressure.messageCount 
    pressure.consumerCount
})

let pressure = await MQ.queue('queue', {job_id: id, data: {}})

MQ.watch('queue', async (job_result) => {
    return true/false for process completion
}, (err, pressure) => {
    //Finised processing item
})