@Override
  public void consume() throws Exception {
    try {
      networkQueue.poll(this::processGetResponse);
    } catch (ShutDownException e) {
      logger.info("Network queue is shutdown");
      throw e;
    } catch (Exception e) {
      logger.error("error in load consumer thread", e);
    }
  }
Polls {@link #networkQueue} and passes the function {@link #processGetResponse(ResponseInfo)} which decodes response
@throws ShutDownException if it encounters {@link ShutDownException}
ambry-tools/src/main/java/com/github/ambry/tools/perf/serverperf/GetLoadProducerConsumer.java