class ParallelProcessingTraverserWorker extends AbstractTraverserWorker implements TraverserWorker {

  @Override
  public void poll() {
    while (!isShutdown.get()) {
      if (queue.size() >= MIN_QUEUE_LOAD_TO_SKIP) {
        logger.info("skipping poll request since queue is full");
        break;
      }
      logger.info("polling entries with request " + pollRequest);
      if (!pollNextBatch()) {
        logger.info("Empty poll response. Try after sometime");
        break;
      }
    }
  }

  public  ParallelProcessingTraverserWorker(
      TraverserConfiguration conf,
      IndexingService indexingService,
      @Nullable ExecutorService executor);

}