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

Class ProcessSetRemovalTimeJobHandler

java.lang.Object

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

org.camunda.bpm.engine.impl.batch.removaltime.ProcessSetRemovalTimeJobHandler

All Implemented Interfaces:

BatchJobHandler<SetRemovalTimeBatchConfiguration>, OptimisticLockingListener, JobHandler<BatchJobConfiguration>

public class ProcessSetRemovalTimeJobHandler
extends AbstractBatchJobHandler<SetRemovalTimeBatchConfiguration>

Author:

Tassilo Weidner

Field Summary

Fields

Modifier and Type	Field	Description
static final BatchJobDeclaration	JOB_DECLARATION
static final int	MAX_CHUNK_SIZE

Constructor Summary

Constructors

Constructor	Description
ProcessSetRemovalTimeJobHandler()

Method Summary

Modifier and Type	Method	Description
protected Map<Class<? extends DbEntity>,DbOperation>	addRemovalTime(String instanceId, Date removalTime, Integer batchSize, Set<String> entities, CommandContext commandContext)
protected Map<Class<? extends DbEntity>,DbOperation>	addRemovalTimeToHierarchy(String rootProcessInstanceId, Date removalTime, Integer batchSize, Set<String> entities, CommandContext commandContext)
protected Map<Class<? extends DbEntity>,DbOperation>	addRemovalTimeToInstance(String instanceId, SetRemovalTimeBatchConfiguration configuration, Integer batchSize, Set<String> entities, CommandContext commandContext)
int	calculateInvocationsPerBatchJob(String batchType, SetRemovalTimeBatchConfiguration configuration)	Determine the number of invocations ber patch job.
protected Date	calculateRemovalTime(HistoricProcessInstanceEntity processInstance, CommandContext commandContext)
protected SetRemovalTimeBatchConfiguration	createJobConfiguration(SetRemovalTimeBatchConfiguration configuration, List<String> processInstanceIds)
protected TransactionListener	createTransactionHandler(SetRemovalTimeBatchConfiguration configuration, Map<Class<? extends DbEntity>,DbOperation> operations, Integer chunkSize, MessageEntity currentJob, CommandExecutor newCommandExecutor)
void	executeHandler(SetRemovalTimeBatchConfiguration configuration, ExecutionEntity execution, CommandContext commandContext, String tenantId)
protected ByteArrayEntity	findByteArrayById(String byteArrayId, CommandContext commandContext)
protected ProcessDefinition	findProcessDefinitionById(String processDefinitionId, CommandContext commandContext)
protected HistoricProcessInstanceEntity	findProcessInstanceById(String instanceId, CommandContext commandContext)
protected String	getHistoryRemovalTimeStrategy(CommandContext commandContext)
JobDeclaration<BatchJobContext,MessageEntity>	getJobDeclaration()	Get the job declaration for batch jobs.
protected SetRemovalTimeJsonConverter	getJsonConverterInstance()
protected Date	getOrCalculateRemovalTime(SetRemovalTimeBatchConfiguration configuration, HistoricProcessInstanceEntity instance, CommandContext commandContext)
String	getType()
protected int	getUpdateChunkSize(SetRemovalTimeBatchConfiguration configuration, CommandContext commandContext)
protected boolean	hasBaseTime(HistoricProcessInstanceEntity instance, CommandContext commandContext)
protected boolean	hasHierarchy(HistoricProcessInstanceEntity instance)
protected boolean	isDmnEnabled(CommandContext commandContext)
protected boolean	isEnded(HistoricProcessInstanceEntity instance)
protected boolean	isStrategyEnd(CommandContext commandContext)
protected boolean	isStrategyStart(CommandContext commandContext)
protected void	registerTransactionHandler(SetRemovalTimeBatchConfiguration configuration, Map<Class<? extends DbEntity>,DbOperation> operations, Integer chunkSize, MessageEntity currentJob, CommandContext commandContext)

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

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

Methods inherited from class java.lang.Object

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

Field Details

JOB_DECLARATION

public static final BatchJobDeclaration JOB_DECLARATION

MAX_CHUNK_SIZE

public static final int MAX_CHUNK_SIZE

See Also:

• Constant Field Values

Constructor Details

ProcessSetRemovalTimeJobHandler

public ProcessSetRemovalTimeJobHandler()

Method Details

executeHandler

public void executeHandler(SetRemovalTimeBatchConfiguration configuration,
 ExecutionEntity execution,
 CommandContext commandContext,
 String tenantId)

Specified by:

executeHandler in class AbstractBatchJobHandler<SetRemovalTimeBatchConfiguration>

addRemovalTimeToInstance

protected Map<Class<? extends DbEntity>,DbOperation> addRemovalTimeToInstance(String instanceId,
 SetRemovalTimeBatchConfiguration configuration,
 Integer batchSize,
 Set<String> entities,
 CommandContext commandContext)

getOrCalculateRemovalTime

protected Date getOrCalculateRemovalTime(SetRemovalTimeBatchConfiguration configuration,
 HistoricProcessInstanceEntity instance,
 CommandContext commandContext)

addRemovalTimeToHierarchy

protected Map<Class<? extends DbEntity>,DbOperation> addRemovalTimeToHierarchy(String rootProcessInstanceId,
 Date removalTime,
 Integer batchSize,
 Set<String> entities,
 CommandContext commandContext)

addRemovalTime

protected Map<Class<? extends DbEntity>,DbOperation> addRemovalTime(String instanceId,
 Date removalTime,
 Integer batchSize,
 Set<String> entities,
 CommandContext commandContext)

hasBaseTime

protected boolean hasBaseTime(HistoricProcessInstanceEntity instance,
 CommandContext commandContext)

isEnded

protected boolean isEnded(HistoricProcessInstanceEntity instance)

isStrategyStart

protected boolean isStrategyStart(CommandContext commandContext)

isStrategyEnd

protected boolean isStrategyEnd(CommandContext commandContext)

hasHierarchy

protected boolean hasHierarchy(HistoricProcessInstanceEntity instance)

getHistoryRemovalTimeStrategy

protected String getHistoryRemovalTimeStrategy(CommandContext commandContext)

findProcessDefinitionById

protected ProcessDefinition findProcessDefinitionById(String processDefinitionId,
 CommandContext commandContext)

isDmnEnabled

protected boolean isDmnEnabled(CommandContext commandContext)

calculateRemovalTime

protected Date calculateRemovalTime(HistoricProcessInstanceEntity processInstance,
 CommandContext commandContext)

findByteArrayById

protected ByteArrayEntity findByteArrayById(String byteArrayId,
 CommandContext commandContext)

findProcessInstanceById

protected HistoricProcessInstanceEntity findProcessInstanceById(String instanceId,
 CommandContext commandContext)

registerTransactionHandler

protected void registerTransactionHandler(SetRemovalTimeBatchConfiguration configuration,
 Map<Class<? extends DbEntity>,DbOperation> operations,
 Integer chunkSize,
 MessageEntity currentJob,
 CommandContext commandContext)

getUpdateChunkSize

protected int getUpdateChunkSize(SetRemovalTimeBatchConfiguration configuration,
 CommandContext commandContext)

createTransactionHandler

protected TransactionListener createTransactionHandler(SetRemovalTimeBatchConfiguration configuration,
 Map<Class<? extends DbEntity>,DbOperation> operations,
 Integer chunkSize,
 MessageEntity currentJob,
 CommandExecutor newCommandExecutor)

getJobDeclaration

public JobDeclaration<BatchJobContext,MessageEntity> getJobDeclaration()

Description copied from interface: BatchJobHandler

Get the job declaration for batch jobs.

Specified by:

getJobDeclaration in interface BatchJobHandler<SetRemovalTimeBatchConfiguration>

Specified by:

getJobDeclaration in class AbstractBatchJobHandler<SetRemovalTimeBatchConfiguration>

Returns:

the batch job declaration

createJobConfiguration

protected SetRemovalTimeBatchConfiguration createJobConfiguration(SetRemovalTimeBatchConfiguration configuration,
 List<String> processInstanceIds)

Specified by:

createJobConfiguration in class AbstractBatchJobHandler<SetRemovalTimeBatchConfiguration>

getJsonConverterInstance

protected SetRemovalTimeJsonConverter getJsonConverterInstance()

Specified by:

getJsonConverterInstance in class AbstractBatchJobHandler<SetRemovalTimeBatchConfiguration>

calculateInvocationsPerBatchJob

public int calculateInvocationsPerBatchJob(String batchType,
 SetRemovalTimeBatchConfiguration configuration)

Description copied from interface: BatchJobHandler

Determine the number of invocations ber patch job. This can be defined by the related batch job handler specifically or otherwise taken from the engine configuration.

Specified by:

calculateInvocationsPerBatchJob in interface BatchJobHandler<SetRemovalTimeBatchConfiguration>

Overrides:

calculateInvocationsPerBatchJob in class AbstractBatchJobHandler<SetRemovalTimeBatchConfiguration>

Parameters:

batchType - the batch's type to help determine any engine configuration related to it

configuration - the configuration object

Returns:

the number of invocations ber patch job

getType

public String getType()