@Override
  public void run() {
    try {
      while (nonBlockingRouter.isOpen.get()) {
        List<RequestInfo> requestsToSend = new ArrayList<>();
        Set<Integer> requestsToDrop = new HashSet<>();
        pollForRequests(requestsToSend, requestsToDrop);

        List<ResponseInfo> responseInfoList = new ArrayList<>();
        for(RequestInfo requestInfo : requestsToSend) {
          responseInfoList.add(new ResponseInfo(requestInfo, true));
        }
        onResponse(responseInfoList);
        responseInfoList.forEach(ResponseInfo::release);
      }
    } catch (Throwable e) {
      logger.error("Aborting, as requestResponseHandlerThread received an unexpected error: ", e);
      routerMetrics.requestResponseHandlerUnexpectedErrorCount.inc();
    } finally {
      // Close the router.
      nonBlockingRouter.shutDownOperationControllers();
    }
  }
An {@link OperationController} implementation, that rejects all requests for quota compliance.
ambry-router/src/test/java/com/github/ambry/router/QuotaRejectingOperationController.java