wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update - REQ-2324-添加日志，job执行任务重试次数用完再钉钉通知

Browse Source
This commit is contained in:
yangqicheng 2024-05-24 17:05:10 +08:00
parent cad75b4100
commit 30ed177cdf
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ApproveErrorReporterEventListener.java
View File

@ -53,6 +53,7 @@ public class ApproveErrorReporterEventListener implements BpmnAsyncJobEventListe
@Override
public void notify(FlowableEvent flowableEvent) {
log.info("ApproveErrorReporterEventListener-flowableEvent: {}", JSONUtil.toJsonStr(flowableEvent));
if (!(flowableEvent instanceof FlowableEntityExceptionEventImpl)) {
return;
}

4
workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ErrorReporterEventListener.java
View File

@ -14,7 +14,7 @@ import org.springframework.stereotype.Component;
import java.util.Objects;
import static org.flowable.common.engine.api.delegate.event.FlowableEngineEventType.JOB_EXECUTION_FAILURE;
import static org.flowable.common.engine.api.delegate.event.FlowableEngineEventType.JOB_MOVED_TO_DEADLETTER;
/**
* 异步任务执行异常的扩展监听器
@ -33,7 +33,7 @@ public class ErrorReporterEventListener implements BpmnAsyncJobEventListener {
@Override
public boolean support(FlowableEngineEventType eventType) {
return Objects.equals(JOB_EXECUTION_FAILURE, eventType);
return Objects.equals(JOB_MOVED_TO_DEADLETTER, eventType);
}
@Override