diff --git a/clearing-parent/swt-importer/src/test/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDBTest.java b/clearing-parent/swt-importer/src/test/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDBTest.java index 192aa31f3..49596bb9d 100644 --- a/clearing-parent/swt-importer/src/test/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDBTest.java +++ b/clearing-parent/swt-importer/src/test/java/ru/spcex/clearing/swt/importer/logic/stages/ImportToDBTest.java @@ -19,6 +19,7 @@ import ru.spcex.clearing.test.config.ImdgTestConfig; import ru.spcex.clearing.test.config.KafkaTestConfig; import ru.spcex.platform.imdg.api.Imdg; import ru.spcex.platform.imdg.api.ImdgProvider; +import ru.spcex.platform.imdg.iml.hazelcast.adapter.ImdgHazelcast; import javax.annotation.PostConstruct; import java.io.File; @@ -97,8 +98,9 @@ class ImportToDBTest { ResultContainer resultContainer = createNewTask(eTable, swtFile); resultContainer.setSwtSource(Files.readAllBytes(Paths.get(swtFile.getAbsolutePath()))); - importToDB.process(resultContainer); Imdg df21Imdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SDf21, SDf21.class); + ((ImdgHazelcast)df21Imdg).clear(); + importToDB.process(resultContainer); Collection values = df21Imdg.getAllValues(); Assertions.assertEquals(13, values.size()); } @@ -111,8 +113,9 @@ class ImportToDBTest { ResultContainer resultContainer = createNewTask(eTable, swtFile); resultContainer.setSwtSource(Files.readAllBytes(Paths.get(swtFile.getAbsolutePath()))); - importToDB.process(resultContainer); Imdg df21Imdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SDf21, SDf21.class); + ((ImdgHazelcast)df21Imdg).clear(); + importToDB.process(resultContainer); Collection values = df21Imdg.getAllValues(); Assertions.assertEquals(3, values.size()); }