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 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 Description DocumentConsumerPolicyBuilder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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, toString, waitMessageForEver, waitMessageTimeout
-
-
-
-
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 classConsumerPolicyBuilder
-
-