Commit 472a0dd8 authored by Labros Papadopoulos's avatar Labros Papadopoulos
Browse files

fix: intercept the dirty state leak because of race condition and manually align the data

parent 8c3806b0

src/test/java/org/etsi/osl/hypo/api/tmf/api/kafka/peering/api/incoming/PeeringApiListenerKafkaTest.java

+14 −2
Original line number Diff line number Diff line
@@ -83,6 +83,8 @@ class PeeringApiListenerKafkaTest { 


    @BeforeEach

    void setUp() {

        Mockito.reset(

                peeringApiListener, serviceSpecificationService, organizationService, peeringHelper);

        incomingChannelCreateSpecs = connector.source(TMF_API_PEERED_ORGANIZATION_SERVICE_SPECS);

        incomingChannelUpdateSpecs = connector.source(UPDATED_PEERED_ORGANIZATION_SERVICE_SPECS);
@@ -110,7 +112,12 @@ class PeeringApiListenerKafkaTest { 
        // PREPARE PAYLOAD

        String specificationId = SPECIFICATION_ID;

        String secondSpecificationId = SECOND_SPECIFICATION_ID;



        try {

            organizationService.updatePeeredOrganizationCharacteristic(

                    ORGANIZATION_ID, PEERED_ORGANIZATION, "false");

        } catch (Exception e) {

            // Safe fallback if transaction containment context differs across modules

        }

        PeeredOrganizationData peeredOrganizationData = new PeeredOrganizationData();

        peeredOrganizationData.setOrganizationId(ORGANIZATION_ID);

        List<ServiceSpecificationEntity> serviceSpecificationEntityList =
@@ -198,7 +205,12 @@ class PeeringApiListenerKafkaTest { 
    void shouldReceiveUpdatedServiceSpecifications() {

        String specificationId = SPECIFICATION_ID;

        String secondSpecificationId = SECOND_SPECIFICATION_ID;



        try {

            organizationService.updatePeeredOrganizationCharacteristic(

                    ORGANIZATION_ID, PEERED_ORGANIZATION, "false");

        } catch (Exception e) {

            // Safe fallback if transaction containment context differs across modules

        }

        // PREPARE FIRST SPECIFICATION

        List<ServiceSpecificationEntity> serviceSpecificationEntityList =

                getServiceSpecificationEntities(specificationId, null);