lib/dataprovider.js
function(message) {
			var response = new DataResponse(message, subscribe, subscribeError);
			if (queueSubUnsubRequest(message, response) === 1) {
				fireFirstSubUnsubEvent(message.itemName);
			} else {
				that.emit("subscribeInQueue", message.itemName);
			}
		}
function(message) {
			var response = new DataResponse(message, subscribe, subscribeError);
			if (queueSubUnsubRequest(message, response) === 1) {
				fireFirstSubUnsubEvent(message.itemName);
			} else {
				that.emit("subscribeInQueue", message.itemName);
			}
		}
function ( message ) { var response = new DataResponse ( message , subscribe , subscribeError ) ; if ( queueSubUnsubRequest ( message , response ) === 1 ) { fireFirstSubUnsubEvent ( message . itemName ) ; } else { that . emit ( "subscribeInQueue" , message . itemName ) ; } }
Handles a subscribe request creating a DataResponse Object and
emitting the subscribe event.

@param {Object} message the incoming request associative array
@private
Handles a subscribe request creating a DataResponse Object and emitting the subscribe event .