From a8ea2d8be0866a6f273a55979e5938eaad20c3a2 Mon Sep 17 00:00:00 2001 From: Harshit-kohli Date: Mon, 8 Apr 2024 13:13:21 -0700 Subject: [PATCH] testing iosas integration --- .../pen/replication/service/EventHandlerDelegatorService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/EventHandlerDelegatorService.java b/api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/EventHandlerDelegatorService.java index 07222b9..4fea9e1 100644 --- a/api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/EventHandlerDelegatorService.java +++ b/api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/EventHandlerDelegatorService.java @@ -109,7 +109,7 @@ public void handleChoreographyEvent(@NonNull final ChoreographedEvent choreograp final SchoolUpdateSagaData schoolUpdateSagaData = SchoolUpdateSagaData.builder() .school(updateSchool) .build(); - val sagaUpdateSchool = this.sagaService.persistSagaData(orchestratorUpdateSchool.getSagaName().getCode(), ApplicationProperties.API_NAME, JsonUtil.getJsonStringFromObject(orchestratorUpdateSchool), choreographedEvent.getEventID()); + val sagaUpdateSchool = this.sagaService.persistSagaData(orchestratorUpdateSchool.getSagaName().getCode(), ApplicationProperties.API_NAME, JsonUtil.getJsonStringFromObject(schoolUpdateSagaData), choreographedEvent.getEventID()); message.ack(); log.info("Acknowledged UPDATE_SCHOOL event to Jet Stream..."); orchestratorUpdateSchool.startSaga(sagaUpdateSchool);