lib/services.js
function Server(svc, opts) {
  opts = opts || {};
  events.EventEmitter.call(this);

  this.service = svc;
  this._handlers = {};
  this._fns = []; // Middleware functions.
  this._channels = {}; // Active channels.
  this._nextChannelId = 1;

  this._cache = opts.cache || {}; // Deprecated.
  this._defaultHandler = opts.defaultHandler;
  this._sysErrFormatter = opts.systemErrorFormatter;
  this._silent = !!opts.silent;
  this._strict = !!opts.strictTypes;

  if (opts.remoteProtocols) {
    insertRemoteProtocols(this._cache, opts.remoteProtocols, svc, false);
  }

  svc.messages.forEach(function (msg) {
    var name = msg.name;
    if (!opts.noCapitalize) {
      name = utils.capitalize(name);
    }
    this['on' + name] = this._createMessageHandler(msg);
  }, this);
}
function Server(svc, opts) {
  opts = opts || {};
  events.EventEmitter.call(this);

  this.service = svc;
  this._handlers = {};
  this._fns = []; // Middleware functions.
  this._channels = {}; // Active channels.
  this._nextChannelId = 1;

  this._cache = opts.cache || {}; // Deprecated.
  this._defaultHandler = opts.defaultHandler;
  this._sysErrFormatter = opts.systemErrorFormatter;
  this._silent = !!opts.silent;
  this._strict = !!opts.strictTypes;

  if (opts.remoteProtocols) {
    insertRemoteProtocols(this._cache, opts.remoteProtocols, svc, false);
  }

  svc.messages.forEach(function (msg) {
    var name = msg.name;
    if (!opts.noCapitalize) {
      name = utils.capitalize(name);
    }
    this['on' + name] = this._createMessageHandler(msg);
  }, this);
}
function Server ( svc , opts ) { opts = opts || { } ; events . EventEmitter . call ( this ) ; this . service = svc ; this . _handlers = { } ; this . _fns = [ ] ; // Middleware functions. this . _channels = { } ; // Active channels. this . _nextChannelId = 1 ; this . _cache = opts . cache || { } ; // Deprecated. this . _defaultHandler = opts . defaultHandler ; this . _sysErrFormatter = opts . systemErrorFormatter ; this . _silent = ! ! opts . silent ; this . _strict = ! ! opts . strictTypes ; if ( opts . remoteProtocols ) { insertRemoteProtocols ( this . _cache , opts . remoteProtocols , svc , false ) ; } svc . messages . forEach ( function ( msg ) { var name = msg . name ; if ( ! opts . noCapitalize ) { name = utils . capitalize ( name ) ; } this [ 'on' + name ] = this . _createMessageHandler ( msg ) ; } , this ) ; }
Message receiver.
Message receiver .