TRAX course replication

Author: arcshiftsolutions

api/src/main/java/ca/bc/gov/educ/api/pen/replication/service/EventHandlerDelegatorService.java

@@ -45,14 +45,15 @@ public EventHandlerDelegatorService(final ChoreographedEventPersistenceService c
    * @throws IOException the io exception
    */
   public void handleChoreographyEvent(@NonNull final ChoreographedEvent choreographedEvent, final Message message) throws IOException {
-    try {
-      final var persistedEvent = this.choreographedEventPersistenceService.persistEventToDB(choreographedEvent);
+//    try {
+//      final var persistedEvent = this.choreographedEventPersistenceService.persistEventToDB(choreographedEvent);
+      log.info("Handling event with ID: " + choreographedEvent.getEventID());
       message.ack(); // acknowledge to Jet Stream that api got the message and it is now in DB.
       log.info("acknowledged to Jet Stream...");
-      this.choreographer.handleEvent(persistedEvent);
-    } catch (final BusinessException businessException) {
-      message.ack(); // acknowledge to Jet Stream that api got the message already...
-      log.info("acknowledged to Jet Stream...");
-    }
+//      this.choreographer.handleEvent(persistedEvent);
+//    } catch (final BusinessException businessException) {
+//      message.ack(); // acknowledge to Jet Stream that api got the message already...
+//      log.info("acknowledged to Jet Stream...");
+//    }
   }
 }