code: function(message) {
  			if (that.listeners(message.verb).length) {
  				var successHandler = function(msg) {
  					reply(proto.writeInit(msg.id));
  				};
  				var errorHandler = function(msg, exceptionMessage, exceptionType) {
  					reply(proto.writeInitException(msg.id, exceptionMessage, exceptionType));
  				};
  				var response = new DataResponse(message, successHandler, errorHandler);
  				that.emit("init", message, response);
  			} else {
  				reply(proto.writeInit(message.id));
  			}
  		}
docs: Handles an initialization request creating a DataResponse Object and
  emitting the subscribe event.
  If the handler is not defined, just writes an ack response.
  
  @param {Object} message the incoming request associative array
  @private