public void save()

in src/main/java/com/epam/digital/data/platform/bphistory/persistence/listener/HistoryTaskListener.java [41:53]


  public void save(HistoryTask input) {
    log.info("Kafka event received");
    if (input != null) {
      log.info(
          "Save Task with id: {}",
          input.getActivityInstanceId());
      if(taskService.isExist(input.getActivityInstanceId())) {
        taskService.update(input);
      } else {
        taskService.create(input);
      }
    }
  }