workerjs-redis

Abstraction layer for using queue and messaging as event listeners.

Messaging

Receive

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");
});

Send

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

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

Queue

Receive

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

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

Send

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

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