org.camunda.bpm.engine.impl.batch.deletion

Class DeleteProcessInstancesJobHandler

java.lang.Object

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

org.camunda.bpm.engine.impl.batch.deletion.DeleteProcessInstancesJobHandler

All Implemented Interfaces:

BatchJobHandler<DeleteProcessInstanceBatchConfiguration>, JobHandler<BatchJobConfiguration>

public class DeleteProcessInstancesJobHandler
extends AbstractBatchJobHandler<DeleteProcessInstanceBatchConfiguration>

Author:

Askar Akhmerov

Field Summary

Fields

Modifier and Type	Field and Description
static BatchJobDeclaration	JOB_DECLARATION

Constructor Summary

Constructors

Constructor and Description
DeleteProcessInstancesJobHandler()

Method Summary

Modifier and Type	Method and Description
protected DeleteProcessInstanceBatchConfiguration	createJobConfiguration(DeleteProcessInstanceBatchConfiguration configuration, List<String> processIdsForJob)
protected void	createJobEntities(BatchEntity batch, DeleteProcessInstanceBatchConfiguration configuration, String deploymentId, List<String> processInstancesToHandle, int invocationsPerBatchJob)
boolean	createJobs(BatchEntity batch) Creates batch jobs for a batch.
void	execute(BatchJobConfiguration configuration, ExecutionEntity execution, CommandContext commandContext, String tenantId)
JobDeclaration<BatchJobContext,MessageEntity>	getJobDeclaration() Get the job declaration for batch jobs.
protected DeleteProcessInstanceBatchConfigurationJsonConverter	getJsonConverterInstance()
String	getType()

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

createBatchJob, deleteJobs, newConfiguration, onDelete, postProcessJob, readConfiguration, 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

DeleteProcessInstancesJobHandler

public DeleteProcessInstancesJobHandler()

Method Detail

getType

public String getType()

getJsonConverterInstance

protected DeleteProcessInstanceBatchConfigurationJsonConverter getJsonConverterInstance()

Specified by:

getJsonConverterInstance in class AbstractBatchJobHandler<DeleteProcessInstanceBatchConfiguration>

getJobDeclaration

public JobDeclaration<BatchJobContext,MessageEntity> getJobDeclaration()

Description copied from interface: BatchJobHandler

Get the job declaration for batch jobs.

Specified by:

getJobDeclaration in interface BatchJobHandler<DeleteProcessInstanceBatchConfiguration>

Specified by:

getJobDeclaration in class AbstractBatchJobHandler<DeleteProcessInstanceBatchConfiguration>

Returns:

the batch job declaration

createJobConfiguration

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

Specified by:

createJobConfiguration in class AbstractBatchJobHandler<DeleteProcessInstanceBatchConfiguration>

execute

public void execute(BatchJobConfiguration configuration,
                    ExecutionEntity execution,
                    CommandContext commandContext,
                    String tenantId)

createJobs

public boolean createJobs(BatchEntity batch)

Description copied from interface: BatchJobHandler

Creates batch jobs for a batch.

Specified by:

createJobs in interface BatchJobHandler<DeleteProcessInstanceBatchConfiguration>

Overrides:

createJobs in class AbstractBatchJobHandler<DeleteProcessInstanceBatchConfiguration>

Parameters:

batch - the batch to create jobs for

Returns:

true of no more jobs have to be created for this batch, false otherwise

createJobEntities

protected void createJobEntities(BatchEntity batch,
                                 DeleteProcessInstanceBatchConfiguration configuration,
                                 String deploymentId,
                                 List<String> processInstancesToHandle,
                                 int invocationsPerBatchJob)