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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
