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

remove - 删除无用的功能

Browse Source
This commit is contained in:
wangli 2024-04-28 22:36:37 +08:00
parent 2abd8050ad
commit a8feabafab
1 changed files with 0 additions and 65 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

65
workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/InitiatorAsyncApprovedListener.java
View File

@ -1,65 +0,0 @@
package cn.axzo.workflow.core.engine.listener;
import lombok.extern.slf4j.Slf4j;
import org.flowable.common.engine.impl.cfg.TransactionListener;
import org.flowable.common.engine.impl.interceptor.CommandContext;
import org.flowable.common.engine.impl.interceptor.CommandContextCloseListener;
import org.flowable.common.engine.impl.interceptor.CommandExecutor;
import org.flowable.job.service.impl.asyncexecutor.AsyncExecutor;
/**
* TODO
*
* @author wangli
* @since 2024/4/28 21:59
*/
@Slf4j
public class InitiatorAsyncApprovedListener implements TransactionListener, CommandContextCloseListener {
protected AsyncExecutor asyncExecutor;
protected CommandExecutor commandExecutor;
public InitiatorAsyncApprovedListener(AsyncExecutor asyncExecutor) {
this.asyncExecutor = asyncExecutor;
}
public InitiatorAsyncApprovedListener(AsyncExecutor asyncExecutor, CommandExecutor commandExecutor) {
this(asyncExecutor);
this.commandExecutor = commandExecutor;
}
@Override
public void execute(CommandContext commandContext) {
// TODO
asyncExecutor.executeAsyncJob();
}
@Override
public void closing(CommandContext commandContext) {
}
@Override
public void afterSessionsFlush(CommandContext commandContext) {
}
@Override
public void closed(CommandContext commandContext) {
execute(commandContext);
}
@Override
public void closeFailure(CommandContext commandContext) {
}
@Override
public Integer order() {
return 10;
}
@Override
public boolean multipleAllowed() {
return true;
}
}