Class MessageCorrelationBatchJobHandler
java.lang.Object
org.camunda.bpm.engine.impl.batch.AbstractBatchJobHandler<MessageCorrelationBatchConfiguration>
org.camunda.bpm.engine.impl.batch.message.MessageCorrelationBatchJobHandler
- All Implemented Interfaces:
BatchJobHandler<MessageCorrelationBatchConfiguration>
,OptimisticLockingListener
,JobHandler<BatchJobConfiguration>
public class MessageCorrelationBatchJobHandler
extends AbstractBatchJobHandler<MessageCorrelationBatchConfiguration>
Job handler for message correlation jobs. The jobs correlate a message to a
list of process instances.
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected MessageCorrelationBatchConfiguration
createJobConfiguration
(MessageCorrelationBatchConfiguration configuration, List<String> processIdsForJob) void
executeHandler
(MessageCorrelationBatchConfiguration batchConfiguration, ExecutionEntity execution, CommandContext commandContext, String tenantId) Get the job declaration for batch jobs.getType()
protected void
postProcessJob
(MessageCorrelationBatchConfiguration configuration, JobEntity job, MessageCorrelationBatchConfiguration jobConfiguration) protected void
setVariables
(String batchId, MessageCorrelationBuilder correlationBuilder, CommandContext commandContext) Methods inherited from class org.camunda.bpm.engine.impl.batch.AbstractBatchJobHandler
calculateInvocationsPerBatchJob, createBatchJob, createJobEntities, createJobs, deleteJobs, execute, failedOperation, getEntityType, newConfiguration, onDelete, readConfiguration, sanitizeMappings, saveConfiguration, writeConfiguration
-
Field Details
-
JOB_DECLARATION
-
-
Constructor Details
-
MessageCorrelationBatchJobHandler
public MessageCorrelationBatchJobHandler()
-
-
Method Details
-
getType
-
getJobDeclaration
Description copied from interface:BatchJobHandler
Get the job declaration for batch jobs.- Specified by:
getJobDeclaration
in interfaceBatchJobHandler<MessageCorrelationBatchConfiguration>
- Specified by:
getJobDeclaration
in classAbstractBatchJobHandler<MessageCorrelationBatchConfiguration>
- Returns:
- the batch job declaration
-
getJsonConverterInstance
- Specified by:
getJsonConverterInstance
in classAbstractBatchJobHandler<MessageCorrelationBatchConfiguration>
-
createJobConfiguration
protected MessageCorrelationBatchConfiguration createJobConfiguration(MessageCorrelationBatchConfiguration configuration, List<String> processIdsForJob) - Specified by:
createJobConfiguration
in classAbstractBatchJobHandler<MessageCorrelationBatchConfiguration>
-
postProcessJob
protected void postProcessJob(MessageCorrelationBatchConfiguration configuration, JobEntity job, MessageCorrelationBatchConfiguration jobConfiguration) - Overrides:
postProcessJob
in classAbstractBatchJobHandler<MessageCorrelationBatchConfiguration>
-
executeHandler
public void executeHandler(MessageCorrelationBatchConfiguration batchConfiguration, ExecutionEntity execution, CommandContext commandContext, String tenantId) - Specified by:
executeHandler
in classAbstractBatchJobHandler<MessageCorrelationBatchConfiguration>
-
setVariables
protected void setVariables(String batchId, MessageCorrelationBuilder correlationBuilder, CommandContext commandContext)
-