Skip to content

Commit 070f810

Browse files
Replication update
1 parent da305d6 commit 070f810

2 files changed

Lines changed: 8 additions & 2 deletions

File tree

api/src/main/java/ca/bc/gov/educ/api/pen/replication/choreographer/ChoreographEventHandler.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,12 @@ public void handleEvent(@NonNull final Event event) {
6969
final EventService<StudentAddress> studentAddressUpdateEventService = (EventService<StudentAddress>) this.eventServiceMap.get(UPDATE_STUDENT_ADDRESS.toString());
7070
studentAddressUpdateEventService.processEvent(studentAddress, event);
7171
break;
72+
case "UPDATE_STUDENT":
73+
log.info("Processing UPDATE_STUDENT event record :: {} ", event);
74+
val studentUpdate = JsonUtil.getJsonObjectFromString(StudentUpdate.class, event.getEventPayload());
75+
final EventService<StudentUpdate> studentUpdateEventService = (EventService<StudentUpdate>) this.eventServiceMap.get(UPDATE_STUDENT.toString());
76+
studentUpdateEventService.processEvent(studentUpdate, event);
77+
break;
7278
case "UPDATE_STUDENT_COURSES":
7379
log.info("Processing UPDATE_STUDENT_COURSES event record :: {} ", event);
7480
val studentCourseUpdateList = JsonUtil.getJsonObjectFromString(StudentCourseUpdate.class, event.getEventPayload());

api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/GradStudentUpdateService.java renamed to api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/StudentUpdateService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,12 +18,12 @@
1818
*/
1919
@Service
2020
@Slf4j
21-
public class GradStudentUpdateService extends BaseService<StudentUpdate> {
21+
public class StudentUpdateService extends BaseService<StudentUpdate> {
2222

2323
private final TraxStudentService traxStudentService;
2424
private final RestUtils restUtils;
2525

26-
public GradStudentUpdateService(final EntityManagerFactory emf, final EventRepository eventRepository, TraxStudentService traxStudentService, final RestUtils restUtils) {
26+
public StudentUpdateService(final EntityManagerFactory emf, final EventRepository eventRepository, TraxStudentService traxStudentService, final RestUtils restUtils) {
2727
super(eventRepository, emf);
2828
this.traxStudentService = traxStudentService;
2929
this.restUtils = restUtils;

0 commit comments

Comments
 (0)