Package org.nuxeo.runtime.stream

Class StreamProcessorDescriptor.PolicyDescriptor

java.lang.Object

org.nuxeo.runtime.stream.StreamProcessorDescriptor.PolicyDescriptor

All Implemented Interfaces:

Descriptor

Enclosing class:

StreamProcessorDescriptor

public static class StreamProcessorDescriptor.PolicyDescriptor
extends Object
implements Descriptor

Field Summary

Fields

Modifier and Type	Field	Description
Integer	batchCapacity
Duration	batchThreshold
Boolean	continueOnFailure
static final Integer	DEFAULT_BATCH_CAPACITY
static final Duration	DEFAULT_BATCH_THRESHOLD
static final Duration	DEFAULT_DELAY
static final Duration	DEFAULT_MAX_DELAY
static final int	DEFAULT_MAX_RETRIES
Duration	delay
Class<? extends StreamComputationPolicy>	klass
Duration	maxDelay
Integer	maxRetries
String	name
Integer	skipFirstFailures

Fields inherited from interface org.nuxeo.runtime.model.Descriptor

UNIQUE_DESCRIPTOR_ID

Constructor Summary

Constructors

Constructor	Description
PolicyDescriptor()

Method Summary

Modifier and Type	Method	Description
ComputationPolicyBuilder	createPolicyBuilder()
String	getId()	The descriptor id, descriptors with same id are merged.
protected int	getSkipFirstFailures()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.nuxeo.runtime.model.Descriptor

doesRemove, merge

Field Details

DEFAULT_MAX_RETRIES

public static final int DEFAULT_MAX_RETRIES

See Also:

• Constant Field Values

DEFAULT_DELAY

public static final Duration DEFAULT_DELAY

DEFAULT_MAX_DELAY

public static final Duration DEFAULT_MAX_DELAY

DEFAULT_BATCH_CAPACITY

public static final Integer DEFAULT_BATCH_CAPACITY

DEFAULT_BATCH_THRESHOLD

public static final Duration DEFAULT_BATCH_THRESHOLD

name

public String name

maxRetries

public Integer maxRetries

delay

public Duration delay

maxDelay

public Duration maxDelay

continueOnFailure

public Boolean continueOnFailure

skipFirstFailures

public Integer skipFirstFailures

klass

public Class<? extends StreamComputationPolicy> klass

batchCapacity

public Integer batchCapacity

batchThreshold

public Duration batchThreshold

Constructor Details

PolicyDescriptor

public PolicyDescriptor()

Method Details

getId

public String getId()

Description copied from interface: Descriptor

The descriptor id, descriptors with same id are merged.

To forbid multiple descriptors use UNIQUE_DESCRIPTOR_ID.

To forbid merge use a unique value, non-overriden toString() for exemple.

Specified by:

getId in interface Descriptor

getSkipFirstFailures

protected int getSkipFirstFailures()

createPolicyBuilder

public ComputationPolicyBuilder createPolicyBuilder()