diff --git a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/DbfImportKafkaMessenger.java b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/DbfImportKafkaMessenger.java index 89f21e00f..4aea5053a 100644 --- a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/DbfImportKafkaMessenger.java +++ b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/DbfImportKafkaMessenger.java @@ -60,12 +60,12 @@ public class DbfImportKafkaMessenger implements InitializingBean { } public void notifyUserAboutErrorParsing(Throwable error, ResultContainer resultContainer) { - if (resultContainer == null || resultContainer.getDbfFile() == null || resultContainer.getDbfTable() == null) + if (resultContainer == null || resultContainer.getDbfFile() == null) return; ETable currTable = resultContainer.getDbfTable(); String fileName = resultContainer.getDbfFile().getName(); log.debug("Notify user about error {} \"{}\"", - resultContainer.getDbfTable(), fileName); + currTable, fileName); sendUserNotification(ObjectType.rgst, String.format("Файл \"%s\" не сохранен", fileName), Priority.HIGH); }