Revert [incubator-kie-issues#1633] Removing blocking completablefutur…

…e.get invocation (#2148 (#2168)
apache · Dec 20, 2024 · aebb2d8 · aebb2d8
1 parent 61ca0fe
commit aebb2d8
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/JobInVMEventPublisher.java b/...addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/JobInVMEventPublisher.java
@@ -20,6 +20,7 @@
 package org.kie.kogito.jobs.embedded;
 
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 import org.eclipse.microprofile.config.inject.ConfigProperty;
 import org.kie.kogito.event.EventPublisher;
@@ -80,9 +81,9 @@ public JobDetails publishJobStatusChange(JobDetails jobDetails) {
                 return jobDetails;
             }
 
-            bus.fireAsync(new EmbeddedJobServiceEvent(jobDetails));
+            bus.fireAsync(new EmbeddedJobServiceEvent(jobDetails)).toCompletableFuture().get();
             return jobDetails;
-        } catch (Exception e) {
+        } catch (InterruptedException | ExecutionException e) {
             throw new RuntimeException(e);
         }
     }