Class SequentialJobAcquisitionRunnable

  • All Implemented Interfaces:
    java.lang.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