Interface BatchJobHandler<T>
-
- All Superinterfaces:
JobHandler<BatchJobConfiguration>
- All Known Implementing Classes:
AbstractBatchJobHandler
,BatchSetRemovalTimeJobHandler
,BatchSetVariablesHandler
,DecisionSetRemovalTimeJobHandler
,DeleteHistoricDecisionInstancesJobHandler
,DeleteHistoricProcessInstancesJobHandler
,DeleteProcessInstancesJobHandler
,MessageCorrelationBatchJobHandler
,MigrationBatchJobHandler
,ModificationBatchJobHandler
,ProcessSetRemovalTimeJobHandler
,RestartProcessInstancesJobHandler
,SetExternalTaskRetriesJobHandler
,SetJobRetriesJobHandler
,UpdateProcessInstancesSuspendStateJobHandler
public interface BatchJobHandler<T> extends JobHandler<BatchJobConfiguration>
A batch job handler manages batch jobs based on the configurationBatchJobHandler
. Used by a seed job to manage lifecycle of execution jobs.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description boolean
createJobs(BatchEntity batch)
Creates batch jobs for a batch.void
deleteJobs(BatchEntity batch)
Delete all jobs for a batch.JobDeclaration<?,MessageEntity>
getJobDeclaration()
Get the job declaration for batch jobs.T
readConfiguration(byte[] serializedConfiguration)
Read the serialized configuration of the batch.byte[]
writeConfiguration(T configuration)
Converts the configuration of the batch to a byte array.-
Methods inherited from interface org.camunda.bpm.engine.impl.jobexecutor.JobHandler
execute, getType, newConfiguration, onDelete
-
-
-
-
Method Detail
-
writeConfiguration
byte[] writeConfiguration(T configuration)
Converts the configuration of the batch to a byte array.- Parameters:
configuration
- the configuration object- Returns:
- the serialized configuration
-
readConfiguration
T readConfiguration(byte[] serializedConfiguration)
Read the serialized configuration of the batch.- Parameters:
serializedConfiguration
- the serialized configuration- Returns:
- the deserialized configuration object
-
getJobDeclaration
JobDeclaration<?,MessageEntity> getJobDeclaration()
Get the job declaration for batch jobs.- Returns:
- the batch job declaration
-
createJobs
boolean createJobs(BatchEntity batch)
Creates batch jobs for a batch.- Parameters:
batch
- the batch to create jobs for- Returns:
- true of no more jobs have to be created for this batch, false otherwise
-
deleteJobs
void deleteJobs(BatchEntity batch)
Delete all jobs for a batch.- Parameters:
batch
- the batch to delete jobs for
-
-