Merge branch 'master' into MODBULKOPS-428

folio-org · Jan 13, 2025 · 6111683 · 6111683
2 parents da8f890 + 9c5e822
commit 6111683
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/src/test/java/org/folio/bulkops/service/DataImportJobCompletionReceiverServiceTest.java b/src/test/java/org/folio/bulkops/service/DataImportJobCompletionReceiverServiceTest.java
@@ -34,11 +34,10 @@ class DataImportJobCompletionReceiverServiceTest extends BaseTest {
   void testReceiveJobExecutionUpdate() {
     var topic = "folio.Default.diku.DI_JOB_COMPLETED";
     var event = Files.readString(Path.of("src/test/resources/files/kafka/data_import_job_completed_message.json"));
-
-    kafkaTemplate.send(topic, OBJECT_MAPPER.readValue(event, Event.class));
-
-    var dataImportJobProfileIdCaptor = ArgumentCaptor.forClass(UUID.class);
-    Awaitility.await().atMost(10, TimeUnit.SECONDS).untilAsserted(() -> verify(bulkOperationService, times(1))
-      .processDataImportResult(dataImportJobProfileIdCaptor.capture()));
+    kafkaTemplate.send(topic, OBJECT_MAPPER.readValue(event, Event.class)).thenAccept(result -> {
+      var dataImportJobProfileIdCaptor = ArgumentCaptor.forClass(UUID.class);
+      Awaitility.await().atMost(20, TimeUnit.SECONDS).untilAsserted(() -> verify(bulkOperationService, times(1))
+        .processDataImportResult(dataImportJobProfileIdCaptor.capture()));
+    });
   }
 }