io.flamingock.internal.core.task.navigation.navigator.strategy

Class NonTxChangeProcessStrategy

java.lang.Object

io.flamingock.internal.core.task.navigation.navigator.strategy.AbstractChangeProcessStrategy<TargetSystemOps>

io.flamingock.internal.core.task.navigation.navigator.strategy.NonTxChangeProcessStrategy

All Implemented Interfaces:

ChangeProcessStrategy

public class NonTxChangeProcessStrategy
extends AbstractChangeProcessStrategy<TargetSystemOps>

Change process strategy for non-transactional target systems.

This strategy is used for target systems that do not support transactions, such as message queues, REST services, S3 buckets, or other external systems where changes cannot be atomically rolled back.

Execution Flow

1. Audit change start in audit store
2. Apply change to target system
3. Audit execution result in audit store
4. If execution failed, attempt manual rollback of change chain

Target System State Outcomes

• Success: Change applied to target system
• Failure: Change not applied, rollback chain applied with best effort

Audit Store State Outcomes

• STARTED: Change execution began but process interrupted
• STARTED → APPLIED: Change successfully applied and audited
• STARTED → FAILED: Change execution failed
• STARTED → FAILED → ROLLED_BACK: Change failed and rollback chain completed

Recovery Considerations

Non-transactional target systems require careful recovery handling since changes cannot be automatically rolled back. The rollback chain mechanism provides best-effort cleanup, but manual intervention may be required for complete system consistency.

Field Summary

Fields inherited from class io.flamingock.internal.core.task.navigation.navigator.strategy.AbstractChangeProcessStrategy

auditStoreOperations, change, executionContext, resultBuilder, stepLogger, targetSystemOps, timeService

Constructor Summary

Constructors

Constructor and Description
NonTxChangeProcessStrategy(ExecutableTask change, ExecutionContext executionContext, TargetSystemOps targetSystem, AuditStoreStepOperations auditStoreOperations, ChangeResultBuilder resultBuilder, LockGuardProxyFactory proxyFactory, io.flamingock.internal.common.core.context.ContextResolver baseContext, io.flamingock.internal.util.TimeService timeService)

Method Summary

Modifier and Type	Method and Description
protected ChangeProcessResult	doApplyChange() Strategy-specific implementation of change application.

Methods inherited from class io.flamingock.internal.core.task.navigation.navigator.strategy.AbstractChangeProcessStrategy

applyChange, auditAndLogAutoRollback, auditAndLogExecution, auditAndLogManualRollback, auditAndLogStartExecution, buildExecutionRuntime

Methods inherited from class java.lang.Object

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

Constructor Detail

NonTxChangeProcessStrategy

public NonTxChangeProcessStrategy(ExecutableTask change,
                                  ExecutionContext executionContext,
                                  TargetSystemOps targetSystem,
                                  AuditStoreStepOperations auditStoreOperations,
                                  ChangeResultBuilder resultBuilder,
                                  LockGuardProxyFactory proxyFactory,
                                  io.flamingock.internal.common.core.context.ContextResolver baseContext,
                                  io.flamingock.internal.util.TimeService timeService)

Method Detail

doApplyChange

protected ChangeProcessResult doApplyChange()

Description copied from class: AbstractChangeProcessStrategy

Strategy-specific implementation of change application.

Concrete strategies must implement this method to define their specific transaction handling, execution flow, and error recovery patterns.

Specified by:

doApplyChange in class AbstractChangeProcessStrategy<TargetSystemOps>

Returns:

Task execution result with success/failure status and details