class BatchProcessingTraverserWorker extends AbstractTraverserWorker implements TraverserWorker {

  @Override
  public void poll() {
    logger.info("polling entries from queue " + pollRequest.getQueue());
    try {
      timeLimiter.callWithTimeout(new ProcessingFunction(), timeout, timeunit);
    } catch (Exception e) {
      logger.log(Level.WARNING, "[" + name + "] Error executing poll request " + pollRequest, e);
    }
  }

  public  BatchProcessingTraverserWorker(
      TraverserConfiguration conf, IndexingService indexingService);

}