Factory for creating core dispatch layers.
Receives job events, checks to see whether any parameters in the job are error tokens or collections which contain errors.
Failure handling dispatch layer, consumes job events with multiple activities and emits the same job but with only the first activity.
Sits above the
Context free invoker layer, does not pass index arrays of jobs into activity instances.
A layer that allows while-style loops.
Configuration bean for the
Dispatch layer which consumes a queue of events and fires off a fixed number of simultaneous jobs to the layer below.
Bean to hold the configuration for the parallelize layer, specifically a single int property defining the number of concurrent jobs in that processor instance per owning process ID.
Implements retry policy with delay between retries and exponential backoff
This layer allows for the cancellation, pausing and resuming of workflow runs.
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.