code: @Override
  	protected void onReceived(Request request, Response response)
  	{
  		activeRequestsCounter.inc();
  		START_TIMES_BY_CORRELATION_ID.put(request.getCorrelationId(), System.nanoTime());
  	}
docs: SECTION: MESSAGE OBSERVER