io.flamingock.internal.core.builder

Class AbstractChangeRunnerBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

java.lang.Object

io.flamingock.internal.core.builder.AbstractBuilder<AUDIT_STORE,HOLDER>

io.flamingock.internal.core.builder.AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>

All Implemented Interfaces:

io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER>, RunnerBuilder, CoreConfigurator<HOLDER>, EventLifecycleConfigurator<HOLDER>

Direct Known Subclasses:

CloudChangeRunnerBuilder, CommunityChangeRunnerBuilder

public abstract class AbstractChangeRunnerBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>
extends AbstractBuilder<AUDIT_STORE,HOLDER>
implements EventLifecycleConfigurator<HOLDER>, RunnerBuilder

Field Summary

Fields

Modifier and Type	Field and Description
protected PluginManager	pluginManager

Fields inherited from class io.flamingock.internal.core.builder.AbstractBuilder

auditStore, context, coreConfiguration, targetSystemManager

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractChangeRunnerBuilder(CoreConfiguration coreConfiguration, io.flamingock.internal.common.core.context.Context context, PluginManager pluginManager)
protected	AbstractChangeRunnerBuilder(CoreConfiguration coreConfiguration, io.flamingock.internal.common.core.context.Context context, PluginManager pluginManager, AUDIT_STORE auditStore)

Method Summary

Modifier and Type	Method and Description
HOLDER	addDependency(java.lang.Class<?> type, java.lang.Object instance)
HOLDER	addDependency(java.lang.Object instance)
HOLDER	addDependency(java.lang.String name, java.lang.Class<?> type, java.lang.Object instance)
HOLDER	addDependency(java.lang.String name, java.lang.Object instance)
HOLDER	addTargetSystem(io.flamingock.api.external.TargetSystem targetSystem)
Runner	build() Builds and returns a configured Flamingock Runner ready for execution.
protected abstract ExecutionPlanner	buildExecutionPlanner(io.flamingock.internal.util.id.RunnerId runnerId)
long	getLockAcquiredForMillis()
java.lang.Long	getLockQuitTryingAfterMillis()
long	getLockTryFrequencyMillis()
java.util.Map<java.lang.String,java.lang.Object>	getMetadata()
java.util.function.Consumer<IPipelineCompletedEvent>	getPipelineCompletedListener() Gets the registered pipeline completed listener.
java.util.function.Consumer<IPipelineFailedEvent>	getPipelineFailureListener() Gets the registered pipeline failed listener.
java.util.function.Consumer<IPipelineIgnoredEvent>	getPipelineIgnoredListener() Gets the registered pipeline ignored listener.
java.util.function.Consumer<IPipelineStartedEvent>	getPipelineStartedListener() Gets the registered pipeline started listener.
protected abstract HOLDER	getSelf()
java.lang.String	getServiceIdentifier()
java.util.function.Consumer<IStageCompletedEvent>	getStageCompletedListener() Gets the registered stage completed listener.
java.util.function.Consumer<IStageFailedEvent>	getStageFailureListener() Gets the registered stage failed listener.
java.util.function.Consumer<IStageIgnoredEvent>	getStageIgnoredListener() Gets the registered stage ignored listener.
java.util.function.Consumer<IStageStartedEvent>	getStageStartedListener() Gets the registered stage started listener.
boolean	isEnabled()
boolean	isThrowExceptionIfCannotObtainLock()
HOLDER	setApplicationArguments(java.lang.String[] args)
HOLDER	setEnabled(boolean enabled)
HOLDER	setLockAcquiredForMillis(long lockAcquiredForMillis)
HOLDER	setLockQuitTryingAfterMillis(java.lang.Long lockQuitTryingAfterMillis)
HOLDER	setLockTryFrequencyMillis(long lockTryFrequencyMillis)
HOLDER	setMetadata(java.util.Map<java.lang.String,java.lang.Object> metadata)
HOLDER	setPipelineCompletedListener(java.util.function.Consumer<IPipelineCompletedEvent> listener) Sets the listener to be notified when a pipeline is successfully completed.
HOLDER	setPipelineFailedListener(java.util.function.Consumer<IPipelineFailedEvent> listener) Sets the listener to be notified when a pipeline fails.
HOLDER	setPipelineIgnoredListener(java.util.function.Consumer<IPipelineIgnoredEvent> listener) Sets the listener to be notified when a pipeline is ignored.
HOLDER	setPipelineStartedListener(java.util.function.Consumer<IPipelineStartedEvent> listener) Sets the listener to be notified when a pipeline is started.
HOLDER	setProperty(io.flamingock.internal.util.Property property)
HOLDER	setProperty(java.lang.String key, java.lang.Boolean value)
HOLDER	setProperty(java.lang.String key, java.lang.Boolean[] value)
HOLDER	setProperty(java.lang.String key, java.lang.Byte[] value)
HOLDER	setProperty(java.lang.String key, java.lang.Character[] value)
HOLDER	setProperty(java.lang.String key, java.nio.charset.Charset value)
HOLDER	setProperty(java.lang.String key, java.util.Currency value)
HOLDER	setProperty(java.lang.String key, java.util.Date value)
HOLDER	setProperty(java.lang.String key, java.sql.Date value)
HOLDER	setProperty(java.lang.String key, java.lang.Double value)
HOLDER	setProperty(java.lang.String key, java.lang.Double[] value)
HOLDER	setProperty(java.lang.String key, java.time.Duration value)
HOLDER	setProperty(java.lang.String key, java.io.File value)
HOLDER	setProperty(java.lang.String key, java.lang.Float value)
HOLDER	setProperty(java.lang.String key, java.lang.Float[] value)
HOLDER	setProperty(java.lang.String key, java.net.InetAddress value)
HOLDER	setProperty(java.lang.String key, java.time.Instant value)
HOLDER	setProperty(java.lang.String key, java.lang.Integer value)
HOLDER	setProperty(java.lang.String key, java.lang.Integer[] value)
HOLDER	setProperty(java.lang.String key, java.time.LocalDate value)
HOLDER	setProperty(java.lang.String key, java.time.LocalDateTime value)
HOLDER	setProperty(java.lang.String key, java.util.Locale value)
HOLDER	setProperty(java.lang.String key, java.time.LocalTime value)
HOLDER	setProperty(java.lang.String key, java.lang.Long value)
HOLDER	setProperty(java.lang.String key, java.lang.Long[] value)
HOLDER	setProperty(java.lang.String key, java.time.OffsetDateTime value)
HOLDER	setProperty(java.lang.String key, java.time.OffsetTime value)
HOLDER	setProperty(java.lang.String key, java.nio.file.Path value)
HOLDER	setProperty(java.lang.String key, java.time.Period value)
HOLDER	setProperty(java.lang.String key, java.lang.Short[] value)
HOLDER	setProperty(java.lang.String key, java.lang.String value)
HOLDER	setProperty(java.lang.String key, java.lang.String[] value)
<T extends java.lang.Enum<T>> HOLDER	setProperty(java.lang.String key, T value)
HOLDER	setProperty(java.lang.String key, java.sql.Time value)
HOLDER	setProperty(java.lang.String key, java.sql.Timestamp value)
HOLDER	setProperty(java.lang.String key, java.net.URI value)
HOLDER	setProperty(java.lang.String key, java.net.URL value)
HOLDER	setProperty(java.lang.String key, java.util.UUID value)
HOLDER	setProperty(java.lang.String key, java.time.ZonedDateTime value)
HOLDER	setServiceIdentifier(java.lang.String serviceIdentifier)
HOLDER	setStageCompletedListener(java.util.function.Consumer<IStageCompletedEvent> listener) Sets the listener to be notified when a stage is successfully completed.
HOLDER	setStageFailedListener(java.util.function.Consumer<IStageFailedEvent> listener) Sets the listener to be notified when a stage fails.
HOLDER	setStageIgnoredListener(java.util.function.Consumer<IStageIgnoredEvent> listener) Sets the listener to be notified when a stage is ignored.
HOLDER	setStageStartedListener(java.util.function.Consumer<IStageStartedEvent> listener) Sets the listener to be notified when a stage is started.
HOLDER	setThrowExceptionIfCannotObtainLock(boolean throwExceptionIfCannotObtainLock)
protected abstract void	updateContextSpecific()

Methods inherited from class io.flamingock.internal.core.builder.AbstractBuilder

configureStoreAndTargetSystem, generateRunnerId, getAuditPersistence, validateAuditStore

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.flamingock.internal.core.configuration.core.CoreConfigurator

addTargetSystems

Field Detail

pluginManager

protected final PluginManager pluginManager

Constructor Detail

AbstractChangeRunnerBuilder

protected AbstractChangeRunnerBuilder(CoreConfiguration coreConfiguration,
                                      io.flamingock.internal.common.core.context.Context context,
                                      PluginManager pluginManager)

AbstractChangeRunnerBuilder

protected AbstractChangeRunnerBuilder(CoreConfiguration coreConfiguration,
                                      io.flamingock.internal.common.core.context.Context context,
                                      PluginManager pluginManager,
                                      AUDIT_STORE auditStore)

Method Detail

setApplicationArguments

public HOLDER setApplicationArguments(java.lang.String[] args)

updateContextSpecific

protected abstract void updateContextSpecific()

buildExecutionPlanner

protected abstract ExecutionPlanner buildExecutionPlanner(io.flamingock.internal.util.id.RunnerId runnerId)

getSelf

protected abstract HOLDER getSelf()

Specified by:

getSelf in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

build

public final Runner build()

Builds and returns a configured Flamingock Runner ready for execution.

This is the central orchestration method that assembles all components into a functional runner. The execution order is critical due to hierarchical dependency resolution - components must be initialized in the correct sequence to ensure all dependencies are available when needed.

Execution Flow Overview:

1. Template Loading - Loads change templates for no-code migrations
2. Context Preparation - Sets up base context with runner ID and core config
3. Plugin Initialization - Initializes plugins with access to base context
4. Hierarchical Context Building - Merges external contexts (e.g., Spring Boot)
5. AuditStore Initialization - Initializes AuditStore with full hierarchical context
6. Persistence Setup - Retrieves AuditPersistence and registers audit writer
7. Pipeline Building - Constructs pipeline and contributes dependencies
8. Runner Creation - Assembles final runner with all components

Critical Order Dependencies:

Hierarchical Context MUST be built before AuditStore initialization. The hierarchical context merges external dependency sources (like Spring Boot's application context) with Flamingock's internal context. When AuditStore.initialize(hierarchicalContext) is called, the AuditStore searches this context for required dependencies (database connections, configuration, etc.). If the hierarchical context is built after AuditStore initialization, these external dependencies won't be available, causing the AuditPersistence to fail during execution.

Component Relationships:

• AuditStore → Engine: AuditStore provides the ConnectionEngine implementation
• Engine → AuditWriter: Engine provides audit writer for execution tracking
• Pipeline → Context: Pipeline contributes additional dependencies back to context
• HierarchicalContext → All Components: Provides unified dependency resolution

Integration Points:

• Plugins: External context merged via buildHierarchicalContext()
• Plugins: Contribute task filters and event publishers
• Templates: Loaded for YAML-based pipeline definitions

Specified by:

build in interface RunnerBuilder

Returns:

A fully configured Runner ready for execution

See Also:

for context merging details, for AuditStore initialization requirements, for pipeline contributions

addTargetSystem

public HOLDER addTargetSystem(io.flamingock.api.external.TargetSystem targetSystem)

Specified by:

addTargetSystem in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

addTargetSystem in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setLockAcquiredForMillis

public HOLDER setLockAcquiredForMillis(long lockAcquiredForMillis)

Specified by:

setLockAcquiredForMillis in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setLockAcquiredForMillis in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setLockQuitTryingAfterMillis

public HOLDER setLockQuitTryingAfterMillis(java.lang.Long lockQuitTryingAfterMillis)

Specified by:

setLockQuitTryingAfterMillis in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setLockQuitTryingAfterMillis in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setLockTryFrequencyMillis

public HOLDER setLockTryFrequencyMillis(long lockTryFrequencyMillis)

Specified by:

setLockTryFrequencyMillis in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setLockTryFrequencyMillis in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setThrowExceptionIfCannotObtainLock

public HOLDER setThrowExceptionIfCannotObtainLock(boolean throwExceptionIfCannotObtainLock)

Specified by:

setThrowExceptionIfCannotObtainLock in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setThrowExceptionIfCannotObtainLock in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setEnabled

public HOLDER setEnabled(boolean enabled)

Specified by:

setEnabled in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setEnabled in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setServiceIdentifier

public HOLDER setServiceIdentifier(java.lang.String serviceIdentifier)

Specified by:

setServiceIdentifier in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setServiceIdentifier in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setMetadata

public HOLDER setMetadata(java.util.Map<java.lang.String,java.lang.Object> metadata)

Specified by:

setMetadata in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setMetadata in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

getLockAcquiredForMillis

public long getLockAcquiredForMillis()

Specified by:

getLockAcquiredForMillis in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

getLockAcquiredForMillis in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

getLockQuitTryingAfterMillis

public java.lang.Long getLockQuitTryingAfterMillis()

Specified by:

getLockQuitTryingAfterMillis in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

getLockQuitTryingAfterMillis in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

getLockTryFrequencyMillis

public long getLockTryFrequencyMillis()

Specified by:

getLockTryFrequencyMillis in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

getLockTryFrequencyMillis in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

isThrowExceptionIfCannotObtainLock

public boolean isThrowExceptionIfCannotObtainLock()

Specified by:

isThrowExceptionIfCannotObtainLock in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

isThrowExceptionIfCannotObtainLock in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

isEnabled in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

getServiceIdentifier

public java.lang.String getServiceIdentifier()

Specified by:

getServiceIdentifier in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

getServiceIdentifier in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

getMetadata

public java.util.Map<java.lang.String,java.lang.Object> getMetadata()

Specified by:

getMetadata in interface CoreConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

getMetadata in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

addDependency

public HOLDER addDependency(java.lang.String name,
                            java.lang.Class<?> type,
                            java.lang.Object instance)

Specified by:

addDependency in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

addDependency in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

addDependency

public HOLDER addDependency(java.lang.Object instance)

Specified by:

addDependency in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

addDependency in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

addDependency

public HOLDER addDependency(java.lang.String name,
                            java.lang.Object instance)

Specified by:

addDependency in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

addDependency in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

addDependency

public HOLDER addDependency(java.lang.Class<?> type,
                            java.lang.Object instance)

Specified by:

addDependency in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

addDependency in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setPipelineStartedListener

public HOLDER setPipelineStartedListener(java.util.function.Consumer<IPipelineStartedEvent> listener)

Description copied from interface: EventLifecycleConfigurator

Sets the listener to be notified when a pipeline is started.

Specified by:

setPipelineStartedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Parameters:

listener - consumer of the pipeline started event

Returns:

fluent builder

setPipelineCompletedListener

public HOLDER setPipelineCompletedListener(java.util.function.Consumer<IPipelineCompletedEvent> listener)

Description copied from interface: EventLifecycleConfigurator

Sets the listener to be notified when a pipeline is successfully completed.

Specified by:

setPipelineCompletedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Parameters:

listener - consumer of the pipeline completed event

Returns:

fluent builder

setPipelineIgnoredListener

public HOLDER setPipelineIgnoredListener(java.util.function.Consumer<IPipelineIgnoredEvent> listener)

Description copied from interface: EventLifecycleConfigurator

Sets the listener to be notified when a pipeline is ignored.

Specified by:

setPipelineIgnoredListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Parameters:

listener - consumer of the pipeline ignored event

Returns:

fluent builder

setPipelineFailedListener

public HOLDER setPipelineFailedListener(java.util.function.Consumer<IPipelineFailedEvent> listener)

Description copied from interface: EventLifecycleConfigurator

Sets the listener to be notified when a pipeline fails.

Specified by:

setPipelineFailedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Parameters:

listener - consumer of the pipeline failed event

Returns:

fluent builder

setStageStartedListener

public HOLDER setStageStartedListener(java.util.function.Consumer<IStageStartedEvent> listener)

Description copied from interface: EventLifecycleConfigurator

Sets the listener to be notified when a stage is started.

Specified by:

setStageStartedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Parameters:

listener - consumer of the stage started event

Returns:

fluent builder

setStageCompletedListener

public HOLDER setStageCompletedListener(java.util.function.Consumer<IStageCompletedEvent> listener)

Description copied from interface: EventLifecycleConfigurator

Sets the listener to be notified when a stage is successfully completed.

Specified by:

setStageCompletedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Parameters:

listener - consumer of the stage completed event

Returns:

fluent builder

setStageIgnoredListener

public HOLDER setStageIgnoredListener(java.util.function.Consumer<IStageIgnoredEvent> listener)

Description copied from interface: EventLifecycleConfigurator

Sets the listener to be notified when a stage is ignored.

Specified by:

setStageIgnoredListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Parameters:

listener - consumer of the stage ignored event

Returns:

fluent builder

setStageFailedListener

public HOLDER setStageFailedListener(java.util.function.Consumer<IStageFailedEvent> listener)

Description copied from interface: EventLifecycleConfigurator

Sets the listener to be notified when a stage fails.

Specified by:

setStageFailedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Parameters:

listener - consumer of the stage failed event

Returns:

fluent builder

getPipelineStartedListener

public java.util.function.Consumer<IPipelineStartedEvent> getPipelineStartedListener()

Description copied from interface: EventLifecycleConfigurator

Gets the registered pipeline started listener.

Specified by:

getPipelineStartedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Returns:

pipeline started event listener

getPipelineCompletedListener

public java.util.function.Consumer<IPipelineCompletedEvent> getPipelineCompletedListener()

Description copied from interface: EventLifecycleConfigurator

Gets the registered pipeline completed listener.

Specified by:

getPipelineCompletedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Returns:

pipeline completed event listener

getPipelineIgnoredListener

public java.util.function.Consumer<IPipelineIgnoredEvent> getPipelineIgnoredListener()

Description copied from interface: EventLifecycleConfigurator

Gets the registered pipeline ignored listener.

Specified by:

getPipelineIgnoredListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Returns:

pipeline ignored event listener

getPipelineFailureListener

public java.util.function.Consumer<IPipelineFailedEvent> getPipelineFailureListener()

Description copied from interface: EventLifecycleConfigurator

Gets the registered pipeline failed listener.

Specified by:

getPipelineFailureListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Returns:

pipeline failed event listener

getStageStartedListener

public java.util.function.Consumer<IStageStartedEvent> getStageStartedListener()

Description copied from interface: EventLifecycleConfigurator

Gets the registered stage started listener.

Specified by:

getStageStartedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Returns:

stage started event listener

getStageCompletedListener

public java.util.function.Consumer<IStageCompletedEvent> getStageCompletedListener()

Description copied from interface: EventLifecycleConfigurator

Gets the registered stage completed listener.

Specified by:

getStageCompletedListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Returns:

stage completed event listener

getStageIgnoredListener

public java.util.function.Consumer<IStageIgnoredEvent> getStageIgnoredListener()

Description copied from interface: EventLifecycleConfigurator

Gets the registered stage ignored listener.

Specified by:

getStageIgnoredListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Returns:

stage ignored event listener

getStageFailureListener

public java.util.function.Consumer<IStageFailedEvent> getStageFailureListener()

Description copied from interface: EventLifecycleConfigurator

Gets the registered stage failed listener.

Specified by:

getStageFailureListener in interface EventLifecycleConfigurator<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Returns:

stage failed event listener

setProperty

public HOLDER setProperty(io.flamingock.internal.util.Property property)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.String value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Boolean value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Integer value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Float value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Long value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Double value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.util.UUID value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.util.Currency value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.util.Locale value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.nio.charset.Charset value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.io.File value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.nio.file.Path value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.net.InetAddress value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.net.URL value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.net.URI value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.time.Duration value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.time.Period value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.time.Instant value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.time.LocalDate value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.time.LocalTime value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.time.LocalDateTime value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.time.ZonedDateTime value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.time.OffsetDateTime value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.time.OffsetTime value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.util.Date value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.sql.Date value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.sql.Time value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.sql.Timestamp value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.String[] value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Integer[] value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Long[] value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Double[] value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Float[] value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Boolean[] value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Byte[] value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Short[] value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public HOLDER setProperty(java.lang.String key,
                          java.lang.Character[] value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

setProperty

public <T extends java.lang.Enum<T>> HOLDER setProperty(java.lang.String key,
                                                        T value)

Specified by:

setProperty in interface io.flamingock.internal.common.core.context.ContextConfigurable<HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>

Overrides:

setProperty in class AbstractBuilder<AUDIT_STORE extends AuditStore<?>,HOLDER extends AbstractChangeRunnerBuilder<AUDIT_STORE,HOLDER>>