private void executeIndexChangeTask()

in src/main/java/com/googlesource/gerrit/plugins/multisite/index/IndexEventHandler.java [108:132]

• 24 lines of code
• 5 McCabe index (conditional complexity)

  private void executeIndexChangeTask(String projectName, int id) {
    if (!Context.isForwardedEvent()) {
      ChangeChecker checker = changeChecker.create(projectName + "~" + id);

      try {
        checker
            .newIndexEvent(projectName, id, false)
            .map(
                event -> {
                  if (Thread.currentThread().getName().contains("Batch")) {
                    return new BatchIndexChangeTask(event);
                  }
                  return new IndexChangeTask(event);
                })
            .ifPresent(
                task -> {
                  if (queuedTasks.add(task)) {
                    executor.execute(task);
                  }
                });
      } catch (Exception e) {
        log.warn("Unable to create task to handle change {}~{}", projectName, id, e);
      }
    }
  }