org.nuxeo.importer.stream.consumer

Class DocumentConsumerPolicyBuilder

java.lang.Object

org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicyBuilder

org.nuxeo.importer.stream.consumer.DocumentConsumerPolicyBuilder

public class DocumentConsumerPolicyBuilder
extends ConsumerPolicyBuilder

Since:

9.2

Field Summary

Fields

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

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

batchPolicy, maxThreads, name, retryPolicy, salted, skipFailure, startOffset, waitMessageTimeout

Constructor Summary

Constructors

Constructor and Description
DocumentConsumerPolicyBuilder()

Method Summary

Modifier and Type	Method and Description
DocumentConsumerPolicyBuilder	blockAsyncListeners(boolean value)
DocumentConsumerPolicyBuilder	blockDefaultSyncListener(boolean value)
DocumentConsumerPolicyBuilder	blockIndexing(boolean value)
DocumentConsumerPolicyBuilder	blockPostCommitListeners(boolean value)
DocumentConsumerPolicy	build()
DocumentConsumerPolicyBuilder	useBulkMode(boolean value)

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

batchPolicy, continueOnFailure, maxThreads, name, retryPolicy, salted, startOffset, waitMessageForEver, waitMessageTimeout

Methods inherited from class java.lang.Object

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

Field Detail

blockIndexing

protected boolean blockIndexing

bulkMode

protected boolean bulkMode

blockAsyncListeners

protected boolean blockAsyncListeners

blockPostCommitListeners

protected boolean blockPostCommitListeners

blockDefaultSyncListener

protected boolean blockDefaultSyncListener

Constructor Detail

DocumentConsumerPolicyBuilder

public DocumentConsumerPolicyBuilder()

Method Detail

blockIndexing

public DocumentConsumerPolicyBuilder blockIndexing(boolean value)

useBulkMode

public DocumentConsumerPolicyBuilder useBulkMode(boolean value)

blockAsyncListeners

public DocumentConsumerPolicyBuilder blockAsyncListeners(boolean value)

blockPostCommitListeners

public DocumentConsumerPolicyBuilder blockPostCommitListeners(boolean value)

blockDefaultSyncListener

public DocumentConsumerPolicyBuilder blockDefaultSyncListener(boolean value)

build

public DocumentConsumerPolicy build()

Overrides:

build in class ConsumerPolicyBuilder