lib/dataprovider.js
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));
			}
		}
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));
			}
		}
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 ) ) ; } }
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
Handles an initialization request creating a DataResponse Object and emitting the subscribe event . If the handler is not defined just writes an ack response .