Class ReindexSwapJobHandler

java.lang.Object

com.flowable.indexing.reindex.job.ReindexSwapJobHandler

All Implemented Interfaces:

org.flowable.job.service.HistoryJobHandler

public class ReindexSwapJobHandler
extends Object
implements org.flowable.job.service.HistoryJobHandler

Performs the atomic alias swap old→new, runs post-swap steps, deletes the dual-write property, and marks the swap part COMPLETED. Idempotent: swapAlias is skipped when the alias already points at the new index (post-swap steps are safe overwrites). If swapAlias throws, the property is not deleted and the part not completed, so dual-write stays active. Services resolved from the CommandContext at execution time to avoid a Spring circular dependency: engine configurers are wired before the engine is fully initialised.

Constructor Summary

Constructors

Constructor	Description
ReindexSwapJobHandler(ElasticsearchClient elasticsearchClient, IndexManager indexManager)

Method Summary

Modifier and Type	Method	Description
void	execute(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job, String configuration, org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration)
String	getType()

Methods inherited from class Object

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

Constructor Details

ReindexSwapJobHandler

public ReindexSwapJobHandler(ElasticsearchClient elasticsearchClient,
 IndexManager indexManager)

Method Details

getType

public String getType()

Specified by:

getType in interface org.flowable.job.service.HistoryJobHandler

execute

public void execute(org.flowable.job.service.impl.persistence.entity.HistoryJobEntity job,
 String configuration,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration)

Specified by:

execute in interface org.flowable.job.service.HistoryJobHandler