This is an automated email from the ASF dual-hosted git repository.

pefernan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-apps.git


The following commit(s) were added to refs/heads/main by this push:
     new c049aea45 [DBACLD-157599] Removing blocking completablefuture.get 
invocation (#2148)
c049aea45 is described below

commit c049aea452987406d6ee5641119818415c4d8ebb
Author: Gabriele Cardosi <[email protected]>
AuthorDate: Wed Dec 4 09:15:44 2024 +0100

    [DBACLD-157599] Removing blocking completablefuture.get invocation (#2148)
    
    Co-authored-by: Gabriele-Cardosi <[email protected]>
---
 .../java/org/kie/kogito/jobs/embedded/JobInVMEventPublisher.java     | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/JobInVMEventPublisher.java
 
b/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/JobInVMEventPublisher.java
index 78434dc84..ba7b0e1ef 100644
--- 
a/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/JobInVMEventPublisher.java
+++ 
b/jobs-service/kogito-addons-jobs-service/kogito-addons-quarkus-jobs/src/main/java/org/kie/kogito/jobs/embedded/JobInVMEventPublisher.java
@@ -20,7 +20,6 @@
 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;
@@ -81,9 +80,9 @@ public class JobInVMEventPublisher implements 
JobEventPublisher {
                 return jobDetails;
             }
 
-            bus.fireAsync(new 
EmbeddedJobServiceEvent(jobDetails)).toCompletableFuture().get();
+            bus.fireAsync(new EmbeddedJobServiceEvent(jobDetails));
             return jobDetails;
-        } catch (InterruptedException | ExecutionException e) {
+        } catch (Exception e) {
             throw new RuntimeException(e);
         }
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to