lib/services/bus.js
function connect(busModule) {
  if (busModule) {
    module.exports.client = busModule.connect();
    BUS_MODULE = true;
  } else {
    log('info', `Connecting to default Redis event bus at ${process.env.CLAY_BUS_HOST}`);
    module.exports.client = new Redis(process.env.CLAY_BUS_HOST);
  }
}
function connect(busModule) {
  if (busModule) {
    module.exports.client = busModule.connect();
    BUS_MODULE = true;
  } else {
    log('info', `Connecting to default Redis event bus at ${process.env.CLAY_BUS_HOST}`);
    module.exports.client = new Redis(process.env.CLAY_BUS_HOST);
  }
}
function connect ( busModule ) { if ( busModule ) { module . exports . client = busModule . connect ( ) ; BUS_MODULE = true ; } else { log ( 'info' , ` ${ process . env . CLAY_BUS_HOST } ` ) ; module . exports . client = new Redis ( process . env . CLAY_BUS_HOST ) ; } }
Connect to the bus Redis instance

@param {Object} busModule
Connect to the bus Redis instance