code: function MsgStream(cfg) {
  	assert(cfg, 'Cannot set up a message stream without configuration');
  	assert(cfg.transports, 'Cannot set up a message stream without transports configured');
  
  	EventEmitter.call(this);
  
  	this.cfg = cfg;
  	this.addressMap = {};
  	this.closing = false;
  }
docs: The Message Stream handler which wraps around all supported transport types
  
  @param {Object} cfg
  @constructor