core-services/uBroker/index.js
function uBrokersManager(){
    var listenClient  = redis.createClient(config.redis[0].port, config.redis[0].server);

    listenClient.on("error", function (err) {
        console.log("Redis listen error " + err);
    });

    listenClient.on('message', function(channel, message) {
        client.get('uBrokers', function(err, reply) {
            uBrokers = JSON.parse(reply);
        });
    });

    listenClient.subscribe('uBrokersChannel');
}
function uBrokersManager(){
    var listenClient  = redis.createClient(config.redis[0].port, config.redis[0].server);

    listenClient.on("error", function (err) {
        console.log("Redis listen error " + err);
    });

    listenClient.on('message', function(channel, message) {
        client.get('uBrokers', function(err, reply) {
            uBrokers = JSON.parse(reply);
        });
    });

    listenClient.subscribe('uBrokersChannel');
}
function uBrokersManager ( ) { var listenClient = redis . createClient ( config . redis [ 0 ] . port , config . redis [ 0 ] . server ) ; listenClient . on ( "error" , function ( err ) { console . log ( "Redis listen error " + err ) ; } ) ; listenClient . on ( 'message' , function ( channel , message ) { client . get ( 'uBrokers' , function ( err , reply ) { uBrokers = JSON . parse ( reply ) ; } ) ; } ) ; listenClient . subscribe ( 'uBrokersChannel' ) ; }
uBroker Manager
Handler the negotiation of messages between uBrokers
uBroker Manager Handler the negotiation of messages between uBrokers