You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kie.apache.org by mw...@apache.org on 2026/04/16 20:29:51 UTC
(incubator-kie-kogito-apps) branch main updated: [Incubator-kie-issues#2269] Fix embedded addon timer repeatLimit signal (#2321)
This is an automated email from the ASF dual-hosted git repository.
mweiler 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 8bda318f7 [Incubator-kie-issues#2269] Fix embedded addon timer repeatLimit signal (#2321)
8bda318f7 is described below
commit 8bda318f726a677ad33bdd21df30182298931437
Author: Abhiram Gundala <16...@users.noreply.github.com>
AuthorDate: Thu Apr 16 16:29:46 2026 -0400
[Incubator-kie-issues#2269] Fix embedded addon timer repeatLimit signal (#2321)
* Fix embedded addon repeatLimit signal
* Using computeRemainingRepetitions for Jackson compatibility
---
.../kie/kogito/app/jobs/integrations/ProcessInstanceJobExecutor.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integrations/ProcessInstanceJobExecutor.java b/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integrations/ProcessInstanceJobExecutor.java
index ed7d77325..43738c1e3 100644
--- a/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integrations/ProcessInstanceJobExecutor.java
+++ b/jobs/jobs-common-embedded/src/main/java/org/kie/kogito/app/jobs/integrations/ProcessInstanceJobExecutor.java
@@ -26,6 +26,7 @@ import org.kie.kogito.process.Processes;
import org.kie.kogito.process.SignalFactory;
import org.kie.kogito.services.uow.UnitOfWorkExecutor;
import org.kie.kogito.timer.TimerInstance;
+import org.kie.kogito.timer.impl.SimpleTimerTrigger;
import org.kie.kogito.uow.UnitOfWorkManager;
public class ProcessInstanceJobExecutor implements JobExecutor {
@@ -52,7 +53,9 @@ public class ProcessInstanceJobExecutor implements JobExecutor {
UnitOfWorkExecutor.executeInUnitOfWork(uom, () -> {
processes.processByProcessInstanceId(processJobDescription.processInstanceId()).ifPresent(processes -> {
processes.instances().findById(processJobDescription.processInstanceId()).ifPresent(pi -> {
- pi.send(SignalFactory.of(SIGNAL, TimerInstance.with(jobDetails.getId(), processJobDescription.timerId(), jobDetails.getRetries())));
+ SimpleTimerTrigger timerTrigger = (SimpleTimerTrigger) jobDetails.getTrigger();
+ int remaining = timerTrigger.computeRemainingRepetitions();
+ pi.send(SignalFactory.of(SIGNAL, TimerInstance.with(jobDetails.getId(), processJobDescription.timerId(), remaining == -1 ? Integer.MAX_VALUE : remaining)));
});
});
return null;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@kie.apache.org
For additional commands, e-mail: commits-help@kie.apache.org