lib/msgServer/msgStream/index.js
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;
}
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;
}
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 ; }
The Message Stream handler which wraps around all supported transport types

@param {Object} cfg
@constructor
The Message Stream handler which wraps around all supported transport types