Class SequentialJobAcquisitionRunnable

java.lang.Object
org.camunda.bpm.engine.impl.jobexecutor.AcquireJobsRunnable
org.camunda.bpm.engine.impl.jobexecutor.SequentialJobAcquisitionRunnable
All Implemented Interfaces:
Runnable

public class SequentialJobAcquisitionRunnable extends AcquireJobsRunnable

AcquireJobsRunnable able to serve multiple process engines.

Continuously acquires jobs for all registered process engines until interruption. For every such acquisition cycle, jobs are acquired and submitted for execution.

For one cycle, all acquisition-related events (acquired jobs by engine, rejected jobs by engine, exceptions during acquisition, etc.) are collected in an instance of JobAcquisitionContext. The context is then handed to a JobAcquisitionStrategy that determines the there is before the next acquisition cycles begins and how many jobs are to be acquired next.

Author:
Daniel Meyer