fetch latest resource from DB

folio-org · Jan 14, 2025 · 6bb84f6 · 6bb84f6
1 parent ff9d7bd
commit 6bb84f6
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/main/java/org/folio/linked/data/integration/ResourceModificationEventListener.java b/src/main/java/org/folio/linked/data/integration/ResourceModificationEventListener.java
@@ -49,9 +49,11 @@ public void afterUpdate(ResourceUpdatedEvent resourceUpdatedEvent) {
   @TransactionalEventListener
   public void afterReplace(ResourceReplacedEvent resourceReplacedEvent) {
     log.info("ResourceReplacedEvent received [{}]", resourceReplacedEvent);
-    replaceMessageSenders.forEach(
-      sender -> sender.produce(resourceReplacedEvent.previous(), resourceReplacedEvent.current())
-    );
+    resourceRepository.findById(resourceReplacedEvent.current().getId())
+      .ifPresent(resource -> replaceMessageSenders.forEach(
+          sender -> sender.produce(resourceReplacedEvent.previous(), resource)
+        )
+      );
   }
 
   @TransactionalEventListener