rsmq-worker
rsmq-worker copied to clipboard
mpneuried
Helper to simply implement a worker around RSMQ ( Redis Simple Message Queue )
Hi there! would it be possible to update the `async` dependency in `rsmq-worker` in order to satisfy `npm audit` ?
Seems to work if you set your dependency to the same version as the package (`"rsmq": "0.7.x"`), but if you instantiate the latest version and pass it in it doesn't...
I am using the RSMQ-worker package to handle messages coming from a Redis instance. Main functionalities are triggered on the 'message' event. When I fail to handle a message, it...
Two urgent issues: 1) Can't install rsmq-worker on systems with node.js version higher than 8, I think is is related to the dependency `rsmq` being outdated. 2) Module `rsmq` has...
Hello. I would like can to see more data in event message. example worker.on( "message", function( msg, next ) { console.log(msg.id, msg.rc, msg.rcf, msg.rc); next(); }); so I can know...
Below is my implementation of RSMQ worker app.queueListener.smsWorker = new RSMQWorker(messagingConfig.queues.sms.queueName, { rsmq, "queueName": "sms", "visibilityTimeout": 60, "sendDelay": 1, "maxReceiveCount": 2 }); app.queueListener.smsWorker.on('message', function (message, next, id) { message =...
Can worker block received messages until one of message will be executed by calling `next()` ?
Suppose I have 100 messages so I want to send 20 messages in batch and after processing I have to delete that batch after processing so is there any option...
