io.flamingock.internal.core.task.executable

Class ReflectionExecutableTask<REFLECTION_TASK_DESCRIPTOR extends AbstractReflectionLoadedTask>

java.lang.Object

io.flamingock.internal.core.task.executable.AbstractExecutableTask<REFLECTION_TASK_DESCRIPTOR>

io.flamingock.internal.core.task.executable.ReflectionExecutableTask<REFLECTION_TASK_DESCRIPTOR>

All Implemented Interfaces:

io.flamingock.internal.common.core.task.TaskDescriptor, ExecutableTask, java.lang.Comparable<io.flamingock.internal.common.core.task.TaskDescriptor>

Direct Known Subclasses:

TemplateExecutableTask

public class ReflectionExecutableTask<REFLECTION_TASK_DESCRIPTOR extends AbstractReflectionLoadedTask>
extends AbstractExecutableTask<REFLECTION_TASK_DESCRIPTOR>
implements ExecutableTask

This class is a reflection version of the ExecutableTask.

It creates a new instance on demand in every execution(apply and rollback), because it's intended to be applied just once. The only case it will be potentially applied twice is if it fails, and in that case will only happen once(in case of sequential execution) or very few times(in case or parallel execution and happen to fail multiple concurrent tasks at the same time),because after that the process will abort.

For this reason it's more optimal to do it on demand, that articulate some synchronisation mechanism.

However, the methods are extracted in advance, so we can spot wrong configuration before starting the process and fail fast.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.reflect.Method	executionMethod
protected java.util.List<Rollback>	rollbackChain

Fields inherited from class io.flamingock.internal.core.task.executable.AbstractExecutableTask

action, descriptor

Constructor Summary

Constructors

Constructor and Description
ReflectionExecutableTask(java.lang.String stageName, REFLECTION_TASK_DESCRIPTOR descriptor, io.flamingock.internal.common.core.recovery.action.ChangeAction action, java.lang.reflect.Method executionMethod, java.lang.reflect.Method rollbackMethod)

Method Summary

Modifier and Type	Method and Description
void	addRollback(Rollback rollback)
void	execute(ExecutionRuntime executionRuntime)
protected void	executeInternal(ExecutionRuntime executionRuntime, java.lang.reflect.Method method)
java.lang.String	getExecutionMethodName()
java.util.List<? extends Rollback>	getRollbackChain()

Methods inherited from class io.flamingock.internal.core.task.executable.AbstractExecutableTask

equals, getAction, getAuthor, getDescriptor, getId, getOrder, getRecovery, getSource, getStageName, getTargetSystem, hashCode, isAlreadyApplied, isLegacy, isRunAlways, isSystem, isTransactional, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.flamingock.internal.core.task.executable.ExecutableTask

getAction, getDescriptor, getStageName, isAlreadyApplied

Methods inherited from interface io.flamingock.internal.common.core.task.TaskDescriptor

compareTo, getAuthor, getId, getOrder, getRecovery, getSource, getTargetSystem, isLegacy, isRunAlways, isSortable, isStandard, isSystem, isTransactional, pretty

Field Detail

executionMethod

protected final java.lang.reflect.Method executionMethod

rollbackChain

protected final java.util.List<Rollback> rollbackChain

Constructor Detail

ReflectionExecutableTask

public ReflectionExecutableTask(java.lang.String stageName,
                                REFLECTION_TASK_DESCRIPTOR descriptor,
                                io.flamingock.internal.common.core.recovery.action.ChangeAction action,
                                java.lang.reflect.Method executionMethod,
                                java.lang.reflect.Method rollbackMethod)

Method Detail

addRollback

public void addRollback(Rollback rollback)

Specified by:

addRollback in interface ExecutableTask

getRollbackChain

public java.util.List<? extends Rollback> getRollbackChain()

Specified by:

getRollbackChain in interface ExecutableTask

execute

public void execute(ExecutionRuntime executionRuntime)

Specified by:

execute in interface ExecutableTask

executeInternal

protected void executeInternal(ExecutionRuntime executionRuntime,
                               java.lang.reflect.Method method)

getExecutionMethodName

public java.lang.String getExecutionMethodName()

Specified by:

getExecutionMethodName in interface ExecutableTask