public List<ResponseInfo> receiveResponses(int processorId, int pollTimeoutMs) {
    List<ResponseInfo> responseList = getResponseQueue(processorId).poll(pollTimeoutMs);
    logger.debug("Returning {} responses for {}", responseList.size(), processorId);
    return responseList;
  }
Receive all queued responses corresponding to requests matching a processor id.
@param processorId the processor id to match.
@param pollTimeoutMs the poll timeout in msec.
@return the applicable responses.
ambry-network/src/main/java/com/github/ambry/network/LocalRequestResponseChannel.java