workerjs-redis

Abstraction layer for using queue and messaging as event listeners.

Messaging

$3

`` javascript
const messaging = require("workerjs-redis")().messaging;

messaging.on("test", function(data){
console.log(data);
}).then(function(){
console.log("Subscribed");
}).catch(function(){
console.log("Error while subscribing");
});

`

$3

` javascript
const messaging = require("workerjs-redis")().messaging;

messaging.emit("test", 123).then(function(){
console.log("Sent");
}).catch(function(){
console.log("Error while sending");
});

`

Queue

$3

` javascript
var queue = require("workerjs-redis")().queue;

queue.on("tasks", function(data){
console.log(data);
});
`

$3

` javascript
var queue = require("workerjs-redis")().queue;

queue.emit("tasks", "123").then(function(){
console.log("Sent");
}).catch(function(){
console.log("Error while sending");
});
``