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 and Description
Integer	batchCapacity
Duration	batchThreshold
Boolean	continueOnFailure
static Integer	DEFAULT_BATCH_CAPACITY
static Duration	DEFAULT_BATCH_THRESHOLD
static Duration	DEFAULT_DELAY
static Duration	DEFAULT_MAX_DELAY
static int	DEFAULT_MAX_RETRIES
Duration	delay
Class<? extends StreamComputationPolicy>	klass
Duration	maxDelay
Integer	maxRetries
String	name

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

UNIQUE_DESCRIPTOR_ID

Constructor Summary

Constructors

Constructor and Description
PolicyDescriptor()

Method Summary

Modifier and Type	Method and Description
String	getId() The descriptor id, descriptors with same id are merged.

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 Detail

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

klass

public Class<? extends StreamComputationPolicy> klass

batchCapacity

public Integer batchCapacity

batchThreshold

public Duration batchThreshold

Constructor Detail

PolicyDescriptor

public PolicyDescriptor()

Method Detail

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