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