news

Author: RuslanLavrov

NEWS.md

@@ -1,6 +1,7 @@
-## 2025-mm-dd v4.5.0-SNAPSHOT
+## 2025-mm-dd v5.0.0-SNAPSHOT
 * [MODSOURCE-919](https://folio-org.atlassian.net/browse/MODSOURCE-919) Fill in permissions header during event sending to Kafka
 * [MODDICORE-464](https://folio-org.atlassian.net/browse/MODDICORE-464) Add links, linking rules setter to MarcBibRecordModifier
+* [MODDICORE-468](https://folio-org.atlassian.net/browse/MODDICORE-468) Upgrade to Vert.x v5.0 and RMB v36.0.0
 
 ## 2025-03-07 v4.4.0
 * [MODDICORE-433](https://folio-org.atlassian.net/browse/MODDICORE-433) Add userId to event header and allow to send events with null token

pom.xml

@@ -3,7 +3,7 @@
 
   <groupId>org.folio</groupId>
   <artifactId>data-import-processing-core</artifactId>
-  <version>4.5.0-SNAPSHOT</version>
+  <version>5.0.0-SNAPSHOT</version>
   <packaging>jar</packaging>
   <name>data-import-processing-core</name>
   <organization>

src/main/java/org/folio/processing/events/services/processor/EventProcessorImpl.java

@@ -26,8 +26,8 @@ public class EventProcessorImpl implements EventProcessor {
 
   @Override
   public CompletableFuture<DataImportEventPayload> process(DataImportEventPayload eventPayload) {
-    LOG.debug("process:: Processing event payload jobExecutionId: {} recordId: {}",
-      eventPayload.getJobExecutionId(), extractRecordId(eventPayload));
+    LOG.debug("process:: Processing event payload, eventType: {} jobExecutionId: {} recordId: {}",
+      eventPayload.getEventType(), eventPayload.getJobExecutionId(), extractRecordId(eventPayload));
     CompletableFuture<DataImportEventPayload> future = new CompletableFuture<>();
     try {
       Optional<EventHandler> optionalEventHandler = eventHandlers.stream()
@@ -90,8 +90,8 @@ private void logEventProcessingTime(String eventType, long startTime, DataImport
           eventType, profileType, profileId, (endTime - startTime) / 1000000L, eventPayload.getJobExecutionId(), extractRecordId(eventPayload));
       }
     } catch (Exception e) {
-      LOG.warn("logEventProcessingTime:: An Exception occurred {} jobExecutionId: {} recordId: {}",
-        e.getMessage(), eventPayload.getJobExecutionId(), extractRecordId(eventPayload));
+      LOG.warn("logEventProcessingTime:: An Exception occurred, jobExecutionId: {} recordId: {}",
+        eventPayload.getJobExecutionId(), extractRecordId(eventPayload), e);
     }
   }
 

src/test/java/org/folio/processing/events/utils/RestUtilTest.java

@@ -165,8 +165,7 @@ public void shouldReturnFailedFutureWhenJsonDoesntParse(TestContext testContext)
     RestUtil.doRequest(params, "/pubsub/publish", HttpMethod.POST, mockItem)
       .onComplete(postPublishResult -> {
         testContext.assertTrue(postPublishResult.failed());
-        Throwable throwable = postPublishResult.cause();
-        testContext.assertTrue(throwable instanceof EncodeException);
+        testContext.assertTrue(postPublishResult.cause() instanceof EncodeException);
         async.complete();
       });
   }