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 booleanblockAsyncListenersprotected booleanblockDefaultSyncListenerprotected booleanblockIndexingprotected booleanblockPostCommitListenersprotected booleanbulkMode-
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 DocumentConsumerPolicyBuilderblockAsyncListeners(boolean value)DocumentConsumerPolicyBuilderblockDefaultSyncListener(boolean value)DocumentConsumerPolicyBuilderblockIndexing(boolean value)DocumentConsumerPolicyBuilderblockPostCommitListeners(boolean value)DocumentConsumerPolicybuild()DocumentConsumerPolicyBuilderuseBulkMode(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:
buildin classConsumerPolicyBuilder
-
-