In the name of ALLAH

This is a simple module that connecto to redis and handle publish and subscribe tasks.

How to use:

just import to your project and create an object like this:

const MsgBroker = require('redis-msg-broker').MsgBroker;
const msg_broker = new MsgBroker(); // have two optional arguments, first get a json object, secound get dev-status .
	

OR

const MsgBroker = require('redis-msg-broker').MsgBroker;
const msg_broker = new MsgBroker({host: "redis-server",port: 6379,db: 16},true);
	

OR

const MsgBroker = require('redis-msg-broker').MsgBroker;
const msg_broker = new MsgBroker({url: 'redis://redis:6379'}),true);				

MsgBroker have two async methods, publish and subscribe.

publish method get an argument {type: String, msg: json} like this example:

msg_broker.publish({type: "news", msg: {subject:"test subject", txt:"this just an example" } }).then((val)=>{console.log(val);}).catch((err)=>{console.log(err)});

subscribe method get an argument {type: String} and every time recive a message with wanted type, emit that msg as json obj, like this example:

msg_broker.subscribe({type: "news"}).then((val)=>{console.log(val);}).catch((err)=>{console.log(err)});

then for handling subscribed "news" we can do like this:

msg_broker.on('news', function (msg) {
	console.log("we recive this msg object ",msg); // msg is an json obj
});