ion-streamer

ION-STREAMER

to produce and consume redis streams in non-blocking manner. ION-Streamer listens to streams in subprocess.

example usage

const StreamManager = require('ion-streamer');
const sm = new StreamManager({prefix: "SL", url: "redis://127.0.0.1:6379"});

/** create consumer **/


const StreamManager = require('./index.js');
const sm = new StreamManager({prefix: "SL", url: "redis://127.0.0.1:6379"});

const consumer = sm.consumer({
    key: 'konafa',
    block: 0,
    keepAlive: true,
    onMessage: (d)=>{console.log(`got message`, d)},
    onError: (d)=>{console.log(`got error`, d)},
    onClose: ()=>{console.log(`got close`)},
})


const producer = sm.producer();

setInterval(()=>{
    producer.emit({key:'konafa', data: {mxg:'1'}});
}, 100);


setTimeout(()=>{consumer.close()}, 7000)