workerjs-redis

2.0.7 • Public • Published

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

/workerjs-redis/

    Package Sidebar

    Install

    npm i workerjs-redis

    Weekly Downloads

    4

    Version

    2.0.7

    License

    MIT

    Unpacked Size

    5.11 kB

    Total Files

    16

    Last publish

    Collaborators

    • nemanjan00