Skip to content

Commit 67d82ab

Browse files
AAJELLALAAJELLAL
authored
Use notifications to manage parameter changes (#614)
* setup params notification. Signed-off-by: AAJELLAL <[email protected]>
1 parent 50fa0aa commit 67d82ab

10 files changed

+72
-4
lines changed

‎src/main/java/org/gridsuite/study/server/notification/NotificationService.java

+12
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88

99
import com.fasterxml.jackson.core.JsonProcessingException;
1010
import com.fasterxml.jackson.databind.ObjectMapper;
11+
import org.gridsuite.study.server.dto.ComputationType;
1112
import org.gridsuite.study.server.dto.StudyIndexationStatus;
1213
import org.gridsuite.study.server.networkmodificationtree.dto.InsertMode;
1314
import org.gridsuite.study.server.notification.dto.NetworkImpactsInfos;
@@ -38,6 +39,7 @@ public class NotificationService {
3839
public static final String HEADER_NODES = "nodes";
3940
public static final String HEADER_STUDY_UUID = "studyUuid";
4041
public static final String HEADER_UPDATE_TYPE = "updateType";
42+
public static final String HEADER_COMPUTATION_TYPE = "computationType";
4143
public static final String HEADER_UPDATE_TYPE_SUBSTATIONS_IDS = "substationsIds";
4244
public static final String HEADER_USER_ID = "userId";
4345
public static final String HEADER_MODIFIED_BY = "modifiedBy";
@@ -80,6 +82,7 @@ public class NotificationService {
8082
public static final String UPDATE_TYPE_STATE_ESTIMATION_FAILED = "stateEstimation_failed";
8183
public static final String UPDATE_TYPE_STATE_ESTIMATION_RESULT = "stateEstimationResult";
8284
public static final String UPDATE_TYPE_STATE_ESTIMATION_STATUS = "stateEstimation_status";
85+
public static final String UPDATE_TYPE_COMPUTATION_PARAMETERS = "computationParametersUpdated";
8386

8487
public static final String MODIFICATIONS_CREATING_IN_PROGRESS = "creatingInProgress";
8588
public static final String MODIFICATIONS_STASHING_IN_PROGRESS = "stashingInProgress";
@@ -166,6 +169,15 @@ public void emitStudyChanged(UUID studyUuid, UUID nodeUuid, String updateType) {
166169
.build());
167170
}
168171

172+
@PostCompletion
173+
public void emitComputationParamsChanged(UUID studyUuid, ComputationType computationType) {
174+
sendUpdateMessage(MessageBuilder.withPayload("")
175+
.setHeader(HEADER_STUDY_UUID, studyUuid)
176+
.setHeader(HEADER_UPDATE_TYPE, UPDATE_TYPE_COMPUTATION_PARAMETERS)
177+
.setHeader(HEADER_COMPUTATION_TYPE, computationType.name())
178+
.build());
179+
}
180+
169181
public void emitStudyCreationError(UUID studyUuid, String userId, String errorMessage) {
170182
sendUpdateMessage(MessageBuilder.withPayload("")
171183
.setHeader(HEADER_STUDY_UUID, studyUuid)

‎src/main/java/org/gridsuite/study/server/service/StudyService.java

+16
Original file line numberDiff line numberDiff line change
@@ -822,6 +822,7 @@ public void setSecurityAnalysisParametersValues(UUID studyUuid, String parameter
822822
createOrUpdateSecurityAnalysisParameters(studyUuid, studyEntity, parameters);
823823
notificationService.emitStudyChanged(studyUuid, null, NotificationService.UPDATE_TYPE_SECURITY_ANALYSIS_STATUS);
824824
notificationService.emitElementUpdated(studyUuid, userId);
825+
notificationService.emitComputationParamsChanged(studyUuid, SECURITY_ANALYSIS);
825826
}
826827

827828
public NonEvacuatedEnergyParametersInfos getNonEvacuatedEnergyParametersInfos(UUID studyUuid) {
@@ -847,6 +848,7 @@ public boolean setLoadFlowParameters(UUID studyUuid, String parameters, String u
847848
notificationService.emitStudyChanged(studyUuid, null, NotificationService.UPDATE_TYPE_NON_EVACUATED_ENERGY_STATUS);
848849
notificationService.emitStudyChanged(studyUuid, null, NotificationService.UPDATE_TYPE_DYNAMIC_SIMULATION_STATUS);
849850
notificationService.emitElementUpdated(studyUuid, userId);
851+
notificationService.emitComputationParamsChanged(studyUuid, LOAD_FLOW);
850852
return userProfileIssue;
851853
}
852854

@@ -877,6 +879,8 @@ public void updateLoadFlowProvider(UUID studyUuid, String provider, String userI
877879
loadflowService.updateLoadFlowProvider(studyEntity.getLoadFlowParametersUuid(), provider);
878880
invalidateLoadFlowStatusOnAllNodes(studyUuid);
879881
notificationService.emitStudyChanged(studyUuid, null, NotificationService.UPDATE_TYPE_LOADFLOW_STATUS);
882+
notificationService.emitComputationParamsChanged(studyUuid, LOAD_FLOW);
883+
880884
});
881885
}
882886

@@ -889,6 +893,7 @@ public void updateSecurityAnalysisProvider(UUID studyUuid, String provider, Stri
889893
securityAnalysisService.updateSecurityAnalysisProvider(studyEntity.getSecurityAnalysisParametersUuid(), provider);
890894
invalidateSecurityAnalysisStatusOnAllNodes(studyUuid);
891895
notificationService.emitStudyChanged(studyUuid, null, NotificationService.UPDATE_TYPE_SECURITY_ANALYSIS_STATUS);
896+
notificationService.emitComputationParamsChanged(studyUuid, SECURITY_ANALYSIS);
892897
});
893898
}
894899

@@ -916,6 +921,7 @@ public void updateDynamicSimulationProvider(UUID studyUuid, String provider, Str
916921
studyEntity.setDynamicSimulationProvider(provider != null ? provider : defaultDynamicSimulationProvider);
917922
invalidateDynamicSimulationStatusOnAllNodes(studyUuid);
918923
notificationService.emitStudyChanged(studyUuid, null, NotificationService.UPDATE_TYPE_DYNAMIC_SIMULATION_STATUS);
924+
notificationService.emitComputationParamsChanged(studyUuid, DYNAMIC_SIMULATION);
919925
});
920926
}
921927

@@ -947,6 +953,8 @@ public void setShortCircuitParameters(UUID studyUuid, @Nullable String shortCirc
947953
studyRepository.save(studyEntity);
948954
}
949955
notificationService.emitElementUpdated(studyUuid, userId);
956+
notificationService.emitComputationParamsChanged(studyUuid, SHORT_CIRCUIT);
957+
950958
}
951959

952960
@Transactional
@@ -1841,6 +1849,8 @@ public void setVoltageInitParameters(UUID studyUuid, StudyVoltageInitParameters
18411849
createOrUpdateVoltageInitParameters(studyEntity, parameters.getComputationParameters());
18421850
notificationService.emitStudyChanged(studyUuid, null, NotificationService.UPDATE_TYPE_VOLTAGE_INIT_STATUS);
18431851
notificationService.emitElementUpdated(studyUuid, userId);
1852+
notificationService.emitComputationParamsChanged(studyUuid, VOLTAGE_INITIALIZATION);
1853+
18441854
}
18451855

18461856
public StudyVoltageInitParameters getVoltageInitParameters(UUID studyUuid) {
@@ -1879,6 +1889,8 @@ public List<ModelInfos> getDynamicSimulationModels(UUID studyUuid, UUID nodeUuid
18791889
public void setDynamicSimulationParameters(UUID studyUuid, DynamicSimulationParametersInfos dsParameter, String userId) {
18801890
updateDynamicSimulationParameters(studyUuid, DynamicSimulationService.toEntity(dsParameter != null ? dsParameter : DynamicSimulationService.getDefaultDynamicSimulationParameters(), objectMapper));
18811891
notificationService.emitElementUpdated(studyUuid, userId);
1892+
notificationService.emitComputationParamsChanged(studyUuid, DYNAMIC_SIMULATION);
1893+
18821894
}
18831895

18841896
public DynamicSimulationParametersInfos getDynamicSimulationParameters(UUID studyUuid) {
@@ -2056,6 +2068,7 @@ public void setSensitivityAnalysisParameters(UUID studyUuid, String parameters,
20562068
createOrUpdateSensitivityAnalysisParameters(studyUuid, parameters);
20572069
notificationService.emitStudyChanged(studyUuid, null, NotificationService.UPDATE_TYPE_SENSITIVITY_ANALYSIS_STATUS);
20582070
notificationService.emitElementUpdated(studyUuid, userId);
2071+
notificationService.emitComputationParamsChanged(studyUuid, SENSITIVITY_ANALYSIS);
20592072
}
20602073

20612074
@Transactional
@@ -2064,6 +2077,8 @@ public void setNonEvacuatedEnergyParametersInfos(UUID studyUuid, NonEvacuatedEne
20642077
NonEvacuatedEnergyService.toEntity(parameters != null ? parameters :
20652078
NonEvacuatedEnergyService.getDefaultNonEvacuatedEnergyParametersInfos()));
20662079
notificationService.emitElementUpdated(studyUuid, userId);
2080+
notificationService.emitComputationParamsChanged(studyUuid, NON_EVACUATED_ENERGY_ANALYSIS);
2081+
20672082
}
20682083

20692084
public void createOrUpdateSensitivityAnalysisParameters(UUID studyUuid, String parameters) {
@@ -2159,6 +2174,7 @@ public void updateNonEvacuatedEnergyProvider(UUID studyUuid, String provider, St
21592174
studyEntity.setNonEvacuatedEnergyProvider(provider != null ? provider : defaultNonEvacuatedEnergyProvider);
21602175
invalidateNonEvacuatedEnergyAnalysisStatusOnAllNodes(studyUuid);
21612176
notificationService.emitStudyChanged(studyUuid, null, NotificationService.UPDATE_TYPE_NON_EVACUATED_ENERGY_STATUS);
2177+
notificationService.emitComputationParamsChanged(studyUuid, NON_EVACUATED_ENERGY_ANALYSIS);
21622178
});
21632179
}
21642180

‎src/test/java/org/gridsuite/study/server/LoadFlowTest.java

+4
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@
6767
import static org.gridsuite.study.server.StudyConstants.HEADER_USER_ID;
6868
import static org.gridsuite.study.server.dto.ComputationType.LOAD_FLOW;
6969
import static org.gridsuite.study.server.notification.NotificationService.HEADER_UPDATE_TYPE;
70+
import static org.gridsuite.study.server.notification.NotificationService.UPDATE_TYPE_COMPUTATION_PARAMETERS;
7071
import static org.junit.Assert.*;
7172
import static org.mockito.ArgumentMatchers.any;
7273
import static org.mockito.Mockito.doAnswer;
@@ -647,6 +648,9 @@ private void createOrUpdateParametersAndDoChecks(UUID studyNameUserIdUuid, Strin
647648

648649
message = output.receive(TIMEOUT, elementUpdateDestination);
649650
assertEquals(studyNameUserIdUuid, message.getHeaders().get(NotificationService.HEADER_ELEMENT_UUID));
651+
message = output.receive(TIMEOUT, studyUpdateDestination);
652+
assertEquals(UPDATE_TYPE_COMPUTATION_PARAMETERS, message.getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
653+
650654
}
651655

652656
@Test

‎src/test/java/org/gridsuite/study/server/NonEvacuatedEnergyTest.java

+3
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@
7272
import static org.gridsuite.study.server.StudyConstants.HEADER_RECEIVER;
7373
import static org.gridsuite.study.server.StudyConstants.HEADER_USER_ID;
7474
import static org.gridsuite.study.server.notification.NotificationService.HEADER_UPDATE_TYPE;
75+
import static org.gridsuite.study.server.notification.NotificationService.UPDATE_TYPE_COMPUTATION_PARAMETERS;
7576
import static org.junit.Assert.*;
7677
import static org.mockito.ArgumentMatchers.any;
7778
import static org.mockito.Mockito.doAnswer;
@@ -658,6 +659,8 @@ public void testNonEvacuatedEnergyParameters() throws Exception {
658659
.contentType(MediaType.APPLICATION_JSON)
659660
.content(myBodyJson)).andExpect(
660661
status().isOk());
662+
Message<byte[]> message = output.receive(TIMEOUT, studyUpdateDestination);
663+
assertEquals(UPDATE_TYPE_COMPUTATION_PARAMETERS, message.getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
661664

662665
mockMvc.perform(get("/v1/studies/{studyUuid}/non-evacuated-energy/parameters", studyNameUserIdUuid)).andExpectAll(
663666
status().isOk(),

‎src/test/java/org/gridsuite/study/server/SecurityAnalysisTest.java

+3
Original file line numberDiff line numberDiff line change
@@ -655,6 +655,7 @@ public void testSecurityAnalysisParameters() throws Exception {
655655
assertTrue(TestUtils.getRequestsDone(1, server).stream().anyMatch(r -> r.matches("/v1/parameters/" + SECURITY_ANALYSIS_PARAMETERS_UUID)));
656656
assertEquals(SECURITY_ANALYSIS_PARAMETERS_UUID, studyRepository.findById(studyNameUserIdUuid).orElseThrow().getSecurityAnalysisParametersUuid());
657657
assertEquals(NotificationService.UPDATE_TYPE_SECURITY_ANALYSIS_STATUS, output.receive(TIMEOUT, studyUpdateDestination).getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
658+
assertEquals(NotificationService.UPDATE_TYPE_COMPUTATION_PARAMETERS, output.receive(TIMEOUT, studyUpdateDestination).getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
658659
//get security analysis parameters but with an already registered securityAnalysisParametersUuid
659660
mockMvc.perform(get("/v1/studies/{studyUuid}/security-analysis/parameters", studyNameUserIdUuid)).andExpectAll(
660661
status().isOk(),
@@ -669,6 +670,7 @@ public void testSecurityAnalysisParameters() throws Exception {
669670
.content(mnBodyJson)).andExpect(
670671
status().isOk());
671672
assertEquals(NotificationService.UPDATE_TYPE_SECURITY_ANALYSIS_STATUS, output.receive(TIMEOUT, studyUpdateDestination).getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
673+
assertEquals(NotificationService.UPDATE_TYPE_COMPUTATION_PARAMETERS, output.receive(TIMEOUT, studyUpdateDestination).getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
672674
assertTrue(TestUtils.getRequestsDone(1, server).stream().anyMatch(r -> r.matches("/v1/parameters/" + SECURITY_ANALYSIS_PARAMETERS_UUID)));
673675
assertEquals(SECURITY_ANALYSIS_PARAMETERS_UUID, studyRepository.findById(studyNameUserIdUuid).orElseThrow().getSecurityAnalysisParametersUuid());
674676
}
@@ -690,6 +692,7 @@ public void testCreateSecurityAnalysisParameters() throws Exception {
690692

691693
assertEquals(SECURITY_ANALYSIS_PARAMETERS_UUID, studyRepository.findById(studyUuid).orElseThrow().getSecurityAnalysisParametersUuid());
692694
assertEquals(NotificationService.UPDATE_TYPE_SECURITY_ANALYSIS_STATUS, output.receive(TIMEOUT, studyUpdateDestination).getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
695+
assertEquals(NotificationService.UPDATE_TYPE_COMPUTATION_PARAMETERS, output.receive(TIMEOUT, studyUpdateDestination).getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
693696
Set<String> requests = TestUtils.getRequestsDone(1, server);
694697
assertTrue(requests.stream().anyMatch(r -> r.matches("/v1/parameters")));
695698
}

‎src/test/java/org/gridsuite/study/server/SensitivityAnalysisTest.java

+8-3
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@
7070
import static org.gridsuite.study.server.StudyConstants.HEADER_USER_ID;
7171
import static org.gridsuite.study.server.dto.ComputationType.SENSITIVITY_ANALYSIS;
7272
import static org.gridsuite.study.server.notification.NotificationService.HEADER_UPDATE_TYPE;
73+
import static org.gridsuite.study.server.notification.NotificationService.UPDATE_TYPE_COMPUTATION_PARAMETERS;
7374
import static org.gridsuite.study.server.utils.TestUtils.getBinaryAsBuffer;
7475
import static org.junit.Assert.*;
7576
import static org.mockito.ArgumentMatchers.any;
@@ -719,9 +720,13 @@ private void setParametersAndDoChecks(UUID studyNameUserIdUuid, String parameter
719720
.content(parameters)).andExpect(
720721
status().isOk());
721722

722-
Message<byte[]> sensiStatusMessage = output.receive(TIMEOUT, studyUpdateDestination);
723-
assertEquals(studyNameUserIdUuid, sensiStatusMessage.getHeaders().get(NotificationService.HEADER_STUDY_UUID));
724-
assertEquals(NotificationService.UPDATE_TYPE_SENSITIVITY_ANALYSIS_STATUS, sensiStatusMessage.getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
723+
Message<byte[]> message = output.receive(TIMEOUT, studyUpdateDestination);
724+
assertEquals(studyNameUserIdUuid, message.getHeaders().get(NotificationService.HEADER_STUDY_UUID));
725+
assertEquals(NotificationService.UPDATE_TYPE_SENSITIVITY_ANALYSIS_STATUS, message.getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
726+
727+
message = output.receive(TIMEOUT, studyUpdateDestination);
728+
assertEquals(studyNameUserIdUuid, message.getHeaders().get(NotificationService.HEADER_STUDY_UUID));
729+
assertEquals(UPDATE_TYPE_COMPUTATION_PARAMETERS, message.getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
725730

726731
Message<byte[]> elementUpdateMessage = output.receive(TIMEOUT, elementUpdateDestination);
727732
assertEquals(studyNameUserIdUuid, elementUpdateMessage.getHeaders().get(NotificationService.HEADER_ELEMENT_UUID));

‎src/test/java/org/gridsuite/study/server/ShortCircuitTest.java

+2
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@
6161
import static org.gridsuite.study.server.StudyConstants.HEADER_RECEIVER;
6262
import static org.gridsuite.study.server.StudyConstants.HEADER_USER_ID;
6363
import static org.gridsuite.study.server.notification.NotificationService.HEADER_UPDATE_TYPE;
64+
import static org.gridsuite.study.server.notification.NotificationService.UPDATE_TYPE_COMPUTATION_PARAMETERS;
6465
import static org.gridsuite.study.server.utils.TestUtils.getBinaryAsBuffer;
6566
import static org.junit.Assert.*;
6667
import static org.mockito.ArgumentMatchers.any;
@@ -282,6 +283,7 @@ public void testShortCircuitAnalysisParameters() throws Exception {
282283
.header(HEADER_USER_ID, "testUserId")
283284
.content("{\"dumb\": \"json\"}").contentType(MediaType.APPLICATION_JSON))
284285
.andExpect(status().isOk());
286+
assertEquals(UPDATE_TYPE_COMPUTATION_PARAMETERS, output.receive(TIMEOUT, studyUpdateDestination).getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
285287
assertTrue(TestUtils.getRequestsDone(1, server).stream().anyMatch(r -> r.equals("/v1/parameters/" + SHORT_CIRCUIT_ANALYSIS_PARAMETERS_UUID)));
286288
}
287289

‎src/test/java/org/gridsuite/study/server/StudyControllerDynamicSimulationTest.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@
6565
import java.util.*;
6666

6767
import static org.assertj.core.api.Assertions.assertThat;
68+
import static org.junit.Assert.assertEquals;
6869
import static org.mockito.BDDMockito.any;
6970
import static org.mockito.BDDMockito.eq;
7071
import static org.mockito.Mockito.when;
@@ -725,11 +726,13 @@ public void testGetDynamicSimulationModelsGivenEmptyMapping() throws Exception {
725726
}
726727

727728
private void checkNotificationsAfterInjectingDynamicSimulationParameters(UUID studyUuid) {
728-
// must have message UPDATE_TYPE_DYNAMIC_SIMULATION_STATUS from channel : studyUpdateDestination
729+
// must have message UPDATE_TYPE_DYNAMIC_SIMULATION_STATUS and UPDATE_TYPE_COMPUTATION_PARAMETERS from channel : studyUpdateDestination
729730
Message<byte[]> studyUpdateMessage = output.receive(TIMEOUT, studyUpdateDestination);
730731
assertThat(studyUpdateMessage.getHeaders())
731732
.containsEntry(NotificationService.HEADER_STUDY_UUID, studyUuid)
732733
.containsEntry(NotificationService.HEADER_UPDATE_TYPE, NotificationService.UPDATE_TYPE_DYNAMIC_SIMULATION_STATUS);
734+
studyUpdateMessage = output.receive(TIMEOUT, studyUpdateDestination);
735+
assertEquals(NotificationService.UPDATE_TYPE_COMPUTATION_PARAMETERS, studyUpdateMessage.getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
733736

734737
// must have message HEADER_USER_ID_VALUE from channel : elementUpdateDestination
735738
Message<byte[]> elementUpdateMessage = output.receive(TIMEOUT, elementUpdateDestination);

‎src/test/java/org/gridsuite/study/server/StudyTest.java

+15
Original file line numberDiff line numberDiff line change
@@ -91,6 +91,7 @@
9191
import static org.gridsuite.study.server.StudyConstants.HEADER_USER_ID;
9292
import static org.gridsuite.study.server.StudyException.Type.STUDY_NOT_FOUND;
9393
import static org.gridsuite.study.server.notification.NotificationService.DEFAULT_ERROR_MESSAGE;
94+
import static org.gridsuite.study.server.notification.NotificationService.UPDATE_TYPE_COMPUTATION_PARAMETERS;
9495
import static org.gridsuite.study.server.utils.MatcherBasicStudyInfos.createMatcherStudyBasicInfos;
9596
import static org.gridsuite.study.server.utils.MatcherCreatedStudyBasicInfos.createMatcherCreatedStudyBasicInfos;
9697
import static org.gridsuite.study.server.utils.MatcherStudyInfos.createMatcherStudyInfos;
@@ -2584,6 +2585,11 @@ public void providerTest() throws Exception {
25842585
Message<byte[]> message = output.receive(TIMEOUT, studyUpdateDestination);
25852586
assertNotNull(message);
25862587
assertEquals(NotificationService.UPDATE_TYPE_LOADFLOW_STATUS, message.getHeaders().get(HEADER_UPDATE_TYPE));
2588+
message = output.receive(TIMEOUT, studyUpdateDestination);
2589+
assertNotNull(message);
2590+
2591+
assertEquals(UPDATE_TYPE_COMPUTATION_PARAMETERS, message.getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
2592+
25872593
assertNotNull(output.receive(TIMEOUT, elementUpdateDestination));
25882594

25892595
mockMvc.perform(post("/v1/studies/{studyUuid}/security-analysis/provider", studyUuid)
@@ -2594,6 +2600,11 @@ public void providerTest() throws Exception {
25942600
message = output.receive(TIMEOUT, studyUpdateDestination);
25952601
assertNotNull(message);
25962602
assertEquals(NotificationService.UPDATE_TYPE_SECURITY_ANALYSIS_STATUS, message.getHeaders().get(HEADER_UPDATE_TYPE));
2603+
2604+
message = output.receive(TIMEOUT, studyUpdateDestination);
2605+
assertNotNull(message);
2606+
assertEquals(UPDATE_TYPE_COMPUTATION_PARAMETERS, message.getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
2607+
25972608
assertNotNull(output.receive(TIMEOUT, elementUpdateDestination));
25982609

25992610
mockMvc.perform(post("/v1/studies/{studyUuid}/non-evacuated-energy/provider", studyUuid)
@@ -2604,6 +2615,10 @@ public void providerTest() throws Exception {
26042615
message = output.receive(TIMEOUT, studyUpdateDestination);
26052616
assertNotNull(message);
26062617
assertEquals(NotificationService.UPDATE_TYPE_NON_EVACUATED_ENERGY_STATUS, message.getHeaders().get(HEADER_UPDATE_TYPE));
2618+
message = output.receive(TIMEOUT, studyUpdateDestination);
2619+
assertNotNull(message);
2620+
assertEquals(UPDATE_TYPE_COMPUTATION_PARAMETERS, message.getHeaders().get(NotificationService.HEADER_UPDATE_TYPE));
2621+
26072622
assertNotNull(output.receive(TIMEOUT, elementUpdateDestination));
26082623

26092624
mockMvc.perform(get("/v1/studies/{studyUuid}/non-evacuated-energy/provider", studyUuid))

0 commit comments

Comments
 (0)