nodredismsg

Messaging framework for Redis

nodredismsg

Messaging framework using Redis

Examples

var nodredismsg = require('nodredismsg');
 
var c = new nodredismsg.connect();
 
var s1 = c.listen_for_operations('multiply', 4);
s1.on('error', console.error);
s1.on('operation', function (operres) {
    console.log(res.id);
    res.answer(oper[0]*oper[1]);
});
 
var s2 = c.listen_for_operations({op:'log', qtt:1, timeout:5, retries:5});
s2.on('error', console.error);
s2.on('operation', function (operres) {
    console.log(oper);
    res.aborted();
});
var nodredismsg = require('nodredismsg');
 
var c = new nodredismsg.connect();
c.request_operation("multiply", [15, 19], function (errid) {
    if(err) {
        console.log(err);
        return;
    }
    c.operation_result(id, 10, function (errans) {
        console.log([err, ans]);
    });
});