Class ConsumerPolicyBuilder
java.lang.Object
org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicyBuilder
- Direct Known Subclasses:
DocumentConsumerPolicyBuilder
- Since:
- 9.2
-
Field Summary
Modifier and TypeFieldDescriptionprotected BatchPolicy
protected short
protected String
protected net.jodah.failsafe.RetryPolicy<Object>
protected boolean
protected boolean
protected ConsumerPolicy.StartOffset
protected Duration
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionbatchPolicy
(BatchPolicy policy) build()
continueOnFailure
(boolean value) Continue on next message even if the retry policy has failed.maxThreads
(short maxThreads) Maximum consumer threads to use.Consumer group name.retryPolicy
(net.jodah.failsafe.RetryPolicy<Object> policy) salted()
Consumer will wait some random time before start, to prevent wave of concurrency in batch processing.startOffset
(ConsumerPolicy.StartOffset startOffset) Where to read the first message.toString()
Consumer will wait for ever message.waitMessageTimeout
(Duration duration) Consumer will stop if there is no more message after this timeout.
-
Field Details
-
batchPolicy
-
retryPolicy
-
skipFailure
protected boolean skipFailure -
waitMessageTimeout
-
startOffset
-
salted
protected boolean salted -
name
-
maxThreads
protected short maxThreads
-
-
Constructor Details
-
ConsumerPolicyBuilder
protected ConsumerPolicyBuilder()
-
-
Method Details
-
batchPolicy
-
retryPolicy
-
continueOnFailure
Continue on next message even if the retry policy has failed. -
maxThreads
Maximum consumer threads to use. The number of threads is limited by the size of the Log. -
waitMessageTimeout
Consumer will stop if there is no more message after this timeout. -
waitMessageForEver
Consumer will wait for ever message. -
startOffset
Where to read the first message. -
salted
Consumer will wait some random time before start, to prevent wave of concurrency in batch processing. -
name
Consumer group name. -
build
-
toString
-