code: public synchronized void addHandler(String handlerId) {
  		// If it is first async handler subscribed, then create the main buffer
  		if (ringBuffer == null) {
  			ringBuffer = new Buffer<Object>(capacity);
  		}
  		/*
  		 * Every new Asynchronous handler starts off with all events from EMQ.
  		 * So we write all EMQ messages directly to RingBuffer
  		 */
  
  		if (earlyMessageQueue != null && earlyMessageQueue.size() != 0) {
  			for (Object message : earlyMessageQueue.toArray()) {
  				if (message != null) {
  					ringBuffer.add(message);
  				}
  			}
  		}
  
  		handlerEventMap.putIfAbsent(handlerId, new HandlerStats(handlerId, sourceId));
  		Tr.event(tc, "Added Asynchronous Handler: " + handlerId);
  	}
docs: Add an asynchronous handler that will consume events from this
  BufferManagerImpl/Conduit's buffer
  
  @param handlerId handlerID to add to this BufferManager