From cd5055ecf3ffc325685e25d6ed946a38b5915727 Mon Sep 17 00:00:00 2001 From: wangli Date: Mon, 11 Aug 2025 14:46:36 +0800 Subject: [PATCH] =?UTF-8?q?feat(REQ-4624)=20-=20=E8=B0=83=E6=95=B4?= =?UTF-8?q?=E8=A7=A6=E5=8F=91=E6=8E=A5=E5=8F=A3=E7=9A=84=E5=BC=82=E6=AD=A5?= =?UTF-8?q?=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/engine/job/AsyncActivityTriggerJobHandler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncActivityTriggerJobHandler.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncActivityTriggerJobHandler.java index c59fe7897..7da1fd889 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncActivityTriggerJobHandler.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncActivityTriggerJobHandler.java @@ -18,7 +18,7 @@ import org.flowable.variable.api.delegate.VariableScope; * @since 2024-09-09 14:36 */ @Slf4j -public class AsyncActivityTriggerJobHandler extends AbstractJobHandler implements JobHandler { +public class AsyncActivityTriggerJobHandler extends AbstractExecuteWithLockJobHandler implements JobHandler { public static final String TYPE = "async-activity-trigger"; @Override @@ -27,7 +27,7 @@ public class AsyncActivityTriggerJobHandler extends AbstractJobHandler implement } @Override - public void execute(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) { + public void executeInternal(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) { log.info("AsyncActivityTriggerJobHandler executing..."); ProcessEngineConfigurationImpl processEngineConfiguration = CommandContextUtil.getProcessEngineConfiguration(commandContext);