Interprocess queue based on Redis that implements EventEmitter interface
npm install redis-event-queueInterprocess queue based on _Redis_ that implements _EventEmitter_ interface
``bash`
npm install --save redis-event-queue
`javascript
var req = require('redis-event-queue')(options);
var wqueue = req.workqueue;
var bqueue = req.broadcast;
for(var i = 0; i < 10; i++) {
wqueue.emit('event', 'work msg '+i);
bqueue.emit('event', 'broad msg '+i);
}
`
`javascript
var req = require('redis-event-queue')(options);
var wqueue = req.workqueue;
var bqueue = req.broadcast;
wqueue.on('event', function(msg) {
console.log('work: '+msg);
});
bqueue.on('event', function(msg) {
console.log('broad: '+msg);
});
``
* prefix: Set keys prefix to use in redis.
All other options are the same as described in redis.
Delivers a message to the first process available
Delivers a message to all processes listening
#Next
Add optional pattern to listen to messages in workqueue an broadcast
#Suggestions
If you have any suggestions, comments or bug reports, please add an issue in github or PR directly!
Thanks.