code: function subscribe(message) {
  		reply(proto.writeSubscribe(message.id));
  		subscritions[message.itemName] = message.id;
  		if (!isSnapshotAvailable(message.itemName)) {
  			notify(proto.writeEndOfSnapshot(message.id, message.itemName));
  		}
  		dequeueSubUnsubRequest(message.itemName);
  		fireFirstSubUnsubEvent(message.itemName);
  	}
docs: Sends a subscribe reply
  
  @param {Object} message the decoded request message
  @private