io.flamingock.internal.core.plan

Class ExecutionPlan

java.lang.Object

io.flamingock.internal.core.plan.ExecutionPlan

All Implemented Interfaces:

java.lang.AutoCloseable

public class ExecutionPlan
extends java.lang.Object
implements java.lang.AutoCloseable

Method Summary

Modifier and Type	Method and Description
static ExecutionPlan	ABORT(java.util.List<ExecutableStage> stages)
void	applyOnEach(io.flamingock.internal.util.TriConsumer<java.lang.String,Lock,ExecutableStage> consumer)
void	close()
static ExecutionPlan	CONTINUE(java.util.List<ExecutableStage> stages)
java.util.List<ExecutableStage>	getExecutableStages()
boolean	isAborted()
boolean	isExecutionRequired()
static ExecutionPlan	newExecution(java.lang.String executionId, Lock lock, java.util.List<ExecutableStage> stages)
void	validate() Validates the execution plan.

Methods inherited from class java.lang.Object

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

Method Detail

newExecution

public static ExecutionPlan newExecution(java.lang.String executionId,
                                         Lock lock,
                                         java.util.List<ExecutableStage> stages)

CONTINUE

public static ExecutionPlan CONTINUE(java.util.List<ExecutableStage> stages)

ABORT

public static ExecutionPlan ABORT(java.util.List<ExecutableStage> stages)

isAborted

public boolean isAborted()

isExecutionRequired

public boolean isExecutionRequired()

getExecutableStages

public java.util.List<ExecutableStage> getExecutableStages()

applyOnEach

public void applyOnEach(io.flamingock.internal.util.TriConsumer<java.lang.String,Lock,ExecutableStage> consumer)

validate

public void validate()

Validates the execution plan.

Checks two conditions:

1. If any changes require manual intervention, throws ManualInterventionRequiredException
2. If the plan is aborted (even without MI changes), throws FlamingockException — the execution planner decided to abort for reasons beyond individual change state

Throws:

io.flamingock.internal.common.core.recovery.ManualInterventionRequiredException - if any changes require manual intervention

io.flamingock.internal.common.core.error.FlamingockException - if the plan is aborted without specific MI changes

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable