Package com.flowable.platform.engine.impl.sandbox.longrunning

Class LongRunningCommandInterruptor

java.lang.Object

org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor

com.flowable.platform.engine.impl.sandbox.longrunning.LongRunningCommandInterruptor

All Implemented Interfaces:

AgendaOperationExecutionListener, CommandInterceptor

public class LongRunningCommandInterruptor
extends AbstractCommandInterceptor
implements AgendaOperationExecutionListener

Author:

Filip Hrisafov

Field Summary

Fields inherited from class org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor

next

Constructor Summary

Constructors

Constructor	Description
LongRunningCommandInterruptor()

Method Summary

Modifier and Type	Method	Description
void	afterExecute(CommandContext commandContext, Runnable runnable)
void	afterExecuteException(CommandContext commandContext, Runnable runnable, Throwable error)
void	beforeExecute(CommandContext commandContext, Runnable runnable)
<T> T	execute(CommandConfig config, Command<T> command, CommandExecutor commandExecutor)
protected Duration	getMaxCommandDuration(String tenantId, PlatformEngineConfiguration platformEngineConfiguration)
protected Duration	getMaxCommandDuration(CommandContext commandContext)
protected void	validateRuntimeWithinLimits(CommandContext commandContext)

Methods inherited from class org.flowable.common.engine.impl.interceptor.AbstractCommandInterceptor

getNext, setNext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LongRunningCommandInterruptor

public LongRunningCommandInterruptor()

Method Details

execute

public <T> T execute(CommandConfig config,
 Command<T> command,
 CommandExecutor commandExecutor)

Specified by:

execute in interface CommandInterceptor

beforeExecute

public void beforeExecute(CommandContext commandContext,
 Runnable runnable)

Specified by:

beforeExecute in interface AgendaOperationExecutionListener

afterExecute

public void afterExecute(CommandContext commandContext,
 Runnable runnable)

Specified by:

afterExecute in interface AgendaOperationExecutionListener

afterExecuteException

public void afterExecuteException(CommandContext commandContext,
 Runnable runnable,
 Throwable error)

Specified by:

afterExecuteException in interface AgendaOperationExecutionListener

validateRuntimeWithinLimits

protected void validateRuntimeWithinLimits(CommandContext commandContext)

getMaxCommandDuration

protected Duration getMaxCommandDuration(CommandContext commandContext)

getMaxCommandDuration

protected Duration getMaxCommandDuration(String tenantId,
 PlatformEngineConfiguration platformEngineConfiguration)