Package org.camunda.bpm.engine.impl.migration.batch

Class MigrationBatchJobHandler

java.lang.Object

org.camunda.bpm.engine.impl.batch.AbstractBatchJobHandler<MigrationBatchConfiguration>

org.camunda.bpm.engine.impl.migration.batch.MigrationBatchJobHandler

All Implemented Interfaces:

BatchJobHandler<MigrationBatchConfiguration>, OptimisticLockingListener, JobHandler<BatchJobConfiguration>

public class MigrationBatchJobHandler
extends AbstractBatchJobHandler<MigrationBatchConfiguration>

Job handler for batch migration jobs. The batch migration job migrates a list of process instances.

Field Summary

Fields

Modifier and Type	Field	Description
static BatchJobDeclaration	JOB_DECLARATION

Constructor Summary

Constructors

Constructor	Description
MigrationBatchJobHandler()

Method Summary

Modifier and Type	Method	Description
protected MigrationBatchConfiguration	createJobConfiguration(MigrationBatchConfiguration configuration, List<String> processIdsForJob)
void	executeHandler(MigrationBatchConfiguration batchConfiguration, ExecutionEntity execution, CommandContext commandContext, String tenantId)
JobDeclaration<BatchJobContext,MessageEntity>	getJobDeclaration()	Get the job declaration for batch jobs.
protected MigrationBatchConfigurationJsonConverter	getJsonConverterInstance()
protected ProcessDefinitionEntity	getProcessDefinition(CommandContext commandContext, String processDefinitionId)
String	getType()
protected void	postProcessJob(MigrationBatchConfiguration configuration, JobEntity job, MigrationBatchConfiguration jobConfiguration)
protected void	setVariables(String batchId, MigrationPlanImpl migrationPlan, CommandContext commandContext)

Methods inherited from class org.camunda.bpm.engine.impl.batch.AbstractBatchJobHandler

createBatchJob, createJobEntities, createJobs, deleteJobs, execute, failedOperation, getEntityType, newConfiguration, onDelete, readConfiguration, sanitizeMappings, saveConfiguration, writeConfiguration

Methods inherited from class java.lang.Object

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

Field Detail

JOB_DECLARATION

public static final BatchJobDeclaration JOB_DECLARATION

Constructor Detail

MigrationBatchJobHandler

public MigrationBatchJobHandler()

Method Detail

getType

public String getType()

getJobDeclaration

public JobDeclaration<BatchJobContext,MessageEntity> getJobDeclaration()

Description copied from interface: BatchJobHandler

Get the job declaration for batch jobs.

Specified by:

getJobDeclaration in interface BatchJobHandler<MigrationBatchConfiguration>

Specified by:

getJobDeclaration in class AbstractBatchJobHandler<MigrationBatchConfiguration>

Returns:

the batch job declaration

getJsonConverterInstance

protected MigrationBatchConfigurationJsonConverter getJsonConverterInstance()

Specified by:

getJsonConverterInstance in class AbstractBatchJobHandler<MigrationBatchConfiguration>

createJobConfiguration

protected MigrationBatchConfiguration createJobConfiguration(MigrationBatchConfiguration configuration,
                                                             List<String> processIdsForJob)

Specified by:

createJobConfiguration in class AbstractBatchJobHandler<MigrationBatchConfiguration>

postProcessJob

protected void postProcessJob(MigrationBatchConfiguration configuration,
                              JobEntity job,
                              MigrationBatchConfiguration jobConfiguration)

Overrides:

postProcessJob in class AbstractBatchJobHandler<MigrationBatchConfiguration>

executeHandler

public void executeHandler(MigrationBatchConfiguration batchConfiguration,
                           ExecutionEntity execution,
                           CommandContext commandContext,
                           String tenantId)

Specified by:

executeHandler in class AbstractBatchJobHandler<MigrationBatchConfiguration>

setVariables

protected void setVariables(String batchId,
                            MigrationPlanImpl migrationPlan,
                            CommandContext commandContext)

getProcessDefinition

protected ProcessDefinitionEntity getProcessDefinition(CommandContext commandContext,
                                                       String processDefinitionId)