Uses of Class
org.nuxeo.lib.stream.computation.ComputationPolicyBuilder
Package
Description
The Computation pattern with a Log implementation.
-
Uses of ComputationPolicyBuilder in org.nuxeo.lib.stream.computation
Modifier and TypeMethodDescriptionComputationPolicyBuilder.batchPolicy
(int capacity, Duration timeThreshold) Defines how to group records by batch using a capacity and a time threshold.ComputationPolicyBuilder.continueOnFailure
(boolean value) The fallback when processing a batch has failed after applying the retry policy has failed.ComputationPolicyBuilder.retryPolicy
(net.jodah.failsafe.RetryPolicy<Object> policy) Defines what to do in case of failure during the batch processing.ComputationPolicyBuilder.skipFirstFailures
(int failures) A recovery fallback that continues processing after failure only for a limited number of time. -
Uses of ComputationPolicyBuilder in org.nuxeo.runtime.stream
Modifier and TypeMethodDescriptionStreamProcessorDescriptor.PolicyDescriptor.createPolicyBuilder()