Package org.flowable.engine.impl.agenda

Class DefaultFlowableEngineAgenda

java.lang.Object

org.flowable.common.engine.impl.agenda.AbstractAgenda

org.flowable.engine.impl.agenda.DefaultFlowableEngineAgenda

All Implemented Interfaces:

Agenda, Session, FlowableEngineAgenda

Direct Known Subclasses:

DebugFlowableEngineAgenda

public class DefaultFlowableEngineAgenda
extends AbstractAgenda
implements FlowableEngineAgenda

For each API call (and thus Command) being executed, a new agenda instance is created. On this agenda, operations are put, which the CommandExecutor will keep executing until all are executed. The agenda also gives easy access to methods to plan new operations when writing ActivityBehavior implementations. During a Command execution, the agenda can always be fetched using CommandContextUtil.getAgenda().

Author:

Joram Barrez

Field Summary

Fields inherited from class org.flowable.common.engine.impl.agenda.AbstractAgenda

commandContext, futureOperations, operations

Constructor Summary

Constructors

Constructor	Description
DefaultFlowableEngineAgenda(CommandContext commandContext)

Method Summary

Modifier and Type	Method	Description
protected AgendaFutureMaxWaitTimeoutProvider	getAgendaFutureMaxWaitTimeoutProvider()
void	planAsyncTriggerExecutionOperation(ExecutionEntity execution)
void	planContinueMultiInstanceOperation(ExecutionEntity execution, ExecutionEntity multiInstanceRootExecution, int loopCounter)
void	planContinueProcessInCompensation(ExecutionEntity execution)
void	planContinueProcessOperation(ExecutionEntity execution)
void	planContinueProcessSynchronousOperation(ExecutionEntity execution)
void	planContinueProcessWithMigrationContextOperation(ExecutionEntity execution, MigrationContext migrationContext)
void	planDestroyScopeOperation(ExecutionEntity execution)
void	planEndExecutionOperation(ExecutionEntity execution)
void	planEndExecutionOperationSynchronous(ExecutionEntity execution)
void	planEvaluateConditionalEventsOperation(ExecutionEntity execution)
void	planEvaluateVariableListenerEventsOperation(String processDefinitionId, String processInstanceId)
void	planExecuteInactiveBehaviorsOperation(Collection<ExecutionEntity> executions)
void	planOperation(Runnable operation, ExecutionEntity executionEntity)	Generic method to plan a Runnable.
void	planTakeOutgoingSequenceFlowsOperation(ExecutionEntity execution, boolean evaluateConditions)
void	planTakeOutgoingSequenceFlowsSynchronousOperation(ExecutionEntity execution, boolean evaluateConditions)
void	planTriggerExecutionOperation(ExecutionEntity execution)

Methods inherited from class org.flowable.common.engine.impl.agenda.AbstractAgenda

assertOperationsNotEmpty, close, flush, getCommandContext, getFutureMaxWaitTimeout, getNextOperation, getOperations, isEmpty, planFutureOperation, planOperation, setCommandContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.flowable.common.engine.impl.agenda.Agenda

getNextOperation, isEmpty, planFutureOperation, planOperation

Methods inherited from interface org.flowable.common.engine.impl.interceptor.Session

close, flush

Constructor Details

DefaultFlowableEngineAgenda

public DefaultFlowableEngineAgenda(CommandContext commandContext)

Method Details

planOperation

public void planOperation(Runnable operation,
 ExecutionEntity executionEntity)

Generic method to plan a Runnable.

Specified by:

planOperation in interface FlowableEngineAgenda

getAgendaFutureMaxWaitTimeoutProvider

protected AgendaFutureMaxWaitTimeoutProvider getAgendaFutureMaxWaitTimeoutProvider()

Specified by:

getAgendaFutureMaxWaitTimeoutProvider in class AbstractAgenda

planContinueProcessOperation

public void planContinueProcessOperation(ExecutionEntity execution)

Specified by:

planContinueProcessOperation in interface FlowableEngineAgenda

planContinueProcessSynchronousOperation

public void planContinueProcessSynchronousOperation(ExecutionEntity execution)

Specified by:

planContinueProcessSynchronousOperation in interface FlowableEngineAgenda

planContinueProcessWithMigrationContextOperation

public void planContinueProcessWithMigrationContextOperation(ExecutionEntity execution,
 MigrationContext migrationContext)

Specified by:

planContinueProcessWithMigrationContextOperation in interface FlowableEngineAgenda

planContinueProcessInCompensation

public void planContinueProcessInCompensation(ExecutionEntity execution)

Specified by:

planContinueProcessInCompensation in interface FlowableEngineAgenda

planContinueMultiInstanceOperation

public void planContinueMultiInstanceOperation(ExecutionEntity execution,
 ExecutionEntity multiInstanceRootExecution,
 int loopCounter)

Specified by:

planContinueMultiInstanceOperation in interface FlowableEngineAgenda

planTakeOutgoingSequenceFlowsOperation

public void planTakeOutgoingSequenceFlowsOperation(ExecutionEntity execution,
 boolean evaluateConditions)

Specified by:

planTakeOutgoingSequenceFlowsOperation in interface FlowableEngineAgenda

planTakeOutgoingSequenceFlowsSynchronousOperation

public void planTakeOutgoingSequenceFlowsSynchronousOperation(ExecutionEntity execution,
 boolean evaluateConditions)

Specified by:

planTakeOutgoingSequenceFlowsSynchronousOperation in interface FlowableEngineAgenda

planEndExecutionOperation

public void planEndExecutionOperation(ExecutionEntity execution)

Specified by:

planEndExecutionOperation in interface FlowableEngineAgenda

planEndExecutionOperationSynchronous

public void planEndExecutionOperationSynchronous(ExecutionEntity execution)

Specified by:

planEndExecutionOperationSynchronous in interface FlowableEngineAgenda

planTriggerExecutionOperation

public void planTriggerExecutionOperation(ExecutionEntity execution)

Specified by:

planTriggerExecutionOperation in interface FlowableEngineAgenda

planAsyncTriggerExecutionOperation

public void planAsyncTriggerExecutionOperation(ExecutionEntity execution)

Specified by:

planAsyncTriggerExecutionOperation in interface FlowableEngineAgenda

planEvaluateConditionalEventsOperation

public void planEvaluateConditionalEventsOperation(ExecutionEntity execution)

Specified by:

planEvaluateConditionalEventsOperation in interface FlowableEngineAgenda

planEvaluateVariableListenerEventsOperation

public void planEvaluateVariableListenerEventsOperation(String processDefinitionId,
 String processInstanceId)

Specified by:

planEvaluateVariableListenerEventsOperation in interface FlowableEngineAgenda

planDestroyScopeOperation

public void planDestroyScopeOperation(ExecutionEntity execution)

Specified by:

planDestroyScopeOperation in interface FlowableEngineAgenda

planExecuteInactiveBehaviorsOperation

public void planExecuteInactiveBehaviorsOperation(Collection<ExecutionEntity> executions)

Specified by:

planExecuteInactiveBehaviorsOperation in interface FlowableEngineAgenda