code: function(message) {
  			var response = new DataResponse(message, subscribe, subscribeError);
  			if (queueSubUnsubRequest(message, response) === 1) {
  				fireFirstSubUnsubEvent(message.itemName);
  			} else {
  				that.emit("subscribeInQueue", message.itemName);
  			}
  		}
docs: Handles a subscribe request creating a DataResponse Object and
  emitting the subscribe event.
  
  @param {Object} message the incoming request associative array
  @private