You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kie.apache.org by pe...@apache.org on 2024/12/04 08:15:49 UTC
(incubator-kie-kogito-apps) branch main updated: [DBACLD-157599] Removing blocking completablefuture.get invocation (#2148)
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 <ga...@gmail.com>
AuthorDate: Wed Dec 4 09:15:44 2024 +0100
[DBACLD-157599] Removing blocking completablefuture.get invocation (#2148)
Co-authored-by: Gabriele-Cardosi <ga...@ibm.com>
---
.../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: commits-unsubscribe@kie.apache.org
For additional commands, e-mail: commits-help@kie.apache.org