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);
}
}
}