public void save()

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


  public void save(HistoryProcess input) {
    log.info("Kafka event received");
    if (input != null) {
      log.info(
          "Save Process with id: {}",
          input.getProcessInstanceId());
      if(processService.isExist(input.getProcessInstanceId())) {
        processService.update(input);
      } else {
        processService.create(input);
      }
    }
  }