Package org.nuxeo.importer.stream.consumer

Class DocumentConsumerPolicy

java.lang.Object

org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy

org.nuxeo.importer.stream.consumer.DocumentConsumerPolicy

public class DocumentConsumerPolicy
extends ConsumerPolicy

Since:

9.2

Nested Class Summary

Nested classes/interfaces inherited from class org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy

ConsumerPolicy.StartOffset

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	blockAsyncListeners
protected boolean	blockDefaultSyncListeners
protected boolean	blockIndexing
protected boolean	blockPostCommitListeners
protected boolean	bulkMode

Fields inherited from class org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy

batchPolicy, BOUNDED, BOUNDED_RETRY, DEFAULT_NAME, maxThreads, name, NO_RETRY, retryPolicy, salted, skipFailure, startOffset, UNBOUNDED, UNBOUNDED_RETRY, waitMessageTimeout

Constructor Summary

Constructors

Constructor	Description
DocumentConsumerPolicy(DocumentConsumerPolicyBuilder builder)

Method Summary

Modifier and Type	Method	Description
boolean	blockAsyncListeners()
boolean	blockDefaultSyncListeners()
boolean	blockIndexing()
boolean	blockPostCommitListeners()
static DocumentConsumerPolicyBuilder	builder()
boolean	bulkMode()
String	toString()

Methods inherited from class org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy

continueOnFailure, getBatchPolicy, getMaxThreads, getName, getRetryPolicy, getStartOffset, getWaitMessageTimeout, isSalted

Methods inherited from class java.lang.Object

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

Field Details

blockIndexing

protected boolean blockIndexing

bulkMode

protected boolean bulkMode

blockAsyncListeners

protected boolean blockAsyncListeners

blockPostCommitListeners

protected boolean blockPostCommitListeners

blockDefaultSyncListeners

protected boolean blockDefaultSyncListeners

Constructor Details

DocumentConsumerPolicy

public DocumentConsumerPolicy(DocumentConsumerPolicyBuilder builder)

Method Details

bulkMode

public boolean bulkMode()

blockAsyncListeners

public boolean blockAsyncListeners()

blockPostCommitListeners

public boolean blockPostCommitListeners()

blockDefaultSyncListeners

public boolean blockDefaultSyncListeners()

blockIndexing

public boolean blockIndexing()

builder

public static DocumentConsumerPolicyBuilder builder()

toString

public String toString()

Overrides:

toString in class ConsumerPolicy