class FullTraversalConnector implements IndexingConnector, IncrementalChangeHandler {

  @Subscribe
  public synchronized void handleAsyncOperation(AsyncApiOperation asyncOp) {
    logger.log(Level.INFO, "Processing an asynchronous repository operation.");
    try {
      String queueName = queueCheckpoint.getCurrentQueueName();
      ExecuteCounter executeCounter = new ExecuteCounter();
      ListenableFuture<List<GenericJson>> future =
          listeningExecutorService.submit(
              new ExecuteOperationCallable(asyncOp.getOperation(), executeCounter, 0L, queueName));
      asyncOp.setResult(future);
    } catch (IOException e) {
      logger.log(
          Level.WARNING,
          "Exception occured while processing an asynchronous repository operation: ", e);
      asyncOp.getResult().cancel(true);
    }
  }

  public  FullTraversalConnector(Repository repository);
  public  FullTraversalConnector(Repository repository, CheckpointHandler checkpointHandler);

}