http://git.mfd.msk/mfd/clearing/issues/6

---
CompanyServiceTest test done

clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/ClearingMemberCategoryServiceTest.java

@@ -154,7 +154,6 @@ class ClearingMemberCategoryServiceTest {
 
         //ASSERT
         Thread.sleep(10000);
-        ClearingMemberCategory resultUpdating = iMap.get(currentId);
         Assertions.assertEquals(0, iMap.size());
 
         //preparing hazelcastImdgProvider for next test

clearing-parent/company-service/src/test/java/ru/spcex/clearing/company/service/CompanyServiceTest.java

@@ -0,0 +1,104 @@
+package ru.spcex.clearing.company.service;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.hazelcast.core.IMap;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.MockConsumer;
+import org.apache.kafka.clients.consumer.OffsetResetStrategy;
+import org.apache.kafka.common.TopicPartition;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+import ru.clearing.classes.statics.data.company.Company;
+import ru.clearing.classes.statics.data.generated.ClearingMemberCategory;
+import ru.spcex.clearing.company.config.HazelcastServiceTestConfiguration;
+import ru.spcex.clearing.company.utils.MatcherFactory;
+import ru.spcex.clearing.imdg.IMDGDistributedNames;
+import ru.spcex.clearing.platform.messaging.domain.ActionType;
+import ru.spcex.clearing.platform.messaging.domain.BaseRequest;
+import ru.spcex.clearing.platform.messaging.domain.Consts;
+import ru.spcex.clearing.platform.messaging.domain.cud.common.CommonDeleteRequest;
+import ru.spcex.platform.imdg.iml.hazelcast.service.HazelcastService;
+
+import java.util.Collections;
+import java.util.HashMap;
+
+import static ru.spcex.clearing.company.utils.MatcherFactory.usingIgnoringFieldsComparator;
+
+@ExtendWith(SpringExtension.class)
+@ContextConfiguration(classes = {
+        HazelcastServiceTestConfiguration.class})
+class CompanyServiceTest {
+
+    public static final MatcherFactory.Matcher<ClearingMemberCategory> COMPANY_MATCHER = usingIgnoringFieldsComparator();
+    private static final int PARTITION = 0;
+    private static final String TOPIC_COMPANY_DELETE = Consts.DESTINATION_COMPANY_DELETE;
+    private static Long currentId = 0L;
+
+    @Autowired
+    @Qualifier("hazelcastServiceTest")
+    private HazelcastService hazelcastServiceTest;
+    private MockConsumer<String, Object> mockConsumer;
+
+    @BeforeEach
+    void setUp() {
+        mockConsumer = new MockConsumer<>(OffsetResetStrategy.EARLIEST);
+    }
+
+    @Test
+    void deleteCompany() throws InterruptedException {
+        //ARRANGE
+        Company existsCompany = new Company();
+        existsCompany.setId(currentId);
+
+        CommonDeleteRequest memberCategoryDeleteRequest = new CommonDeleteRequest();
+        memberCategoryDeleteRequest.setId(currentId);
+
+        BaseRequest<CommonDeleteRequest> baseDeleteRequest = new BaseRequest<>();
+        baseDeleteRequest.setRequestPayload(memberCategoryDeleteRequest);
+        baseDeleteRequest.setId(currentId);
+        baseDeleteRequest.setActionType(ActionType.DELETE);
+        String jsonBaseForDeleteRequest;
+        ObjectMapper objectMapper = new ObjectMapper();
+        try {
+            jsonBaseForDeleteRequest = objectMapper.writeValueAsString(baseDeleteRequest);
+        } catch (JsonProcessingException e) {
+            throw new RuntimeException(e);
+        }
+
+        //ACT
+        //service set up
+        CompanyService companyService = new CompanyService(mockConsumer, hazelcastServiceTest);
+        Thread.sleep(10000);
+        //callbacks set up
+        companyService.afterPropertiesSet();
+        Thread.sleep(10000);
+
+        IMap<Long, Company> iMap = hazelcastServiceTest.getHazelcast().getMap(IMDGDistributedNames.Map_Company);
+        iMap.put(currentId, existsCompany);
+
+        //KAFKA
+        mockConsumer.schedulePollTask(() -> {
+            mockConsumer.rebalance(Collections.singletonList(new TopicPartition(TOPIC_COMPANY_DELETE, PARTITION)));
+            mockConsumer.addRecord(new ConsumerRecord<>(TOPIC_COMPANY_DELETE, PARTITION, 0, "key", jsonBaseForDeleteRequest));
+        });
+        HashMap<TopicPartition, Long> startOffsetsUpdating = new HashMap<>();
+        TopicPartition tpDeleting = new TopicPartition(TOPIC_COMPANY_DELETE, PARTITION);
+        startOffsetsUpdating.put(tpDeleting, 0L);
+        mockConsumer.updateBeginningOffsets(startOffsetsUpdating);
+
+        //ASSERT
+        Thread.sleep(10000);
+        Assertions.assertEquals(0, iMap.size());
+
+        //preparing hazelcastImdgProvider for next test
+        iMap.clear();
+        currentId++;
+    }
+}