Uses of Class
org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicyBuilder

Packages that use ConsumerPolicyBuilder

Package	Description
org.nuxeo.importer.stream.consumer
org.nuxeo.lib.stream.pattern.consumer

Uses of ConsumerPolicyBuilder in org.nuxeo.importer.stream.consumer

Subclasses of ConsumerPolicyBuilder in org.nuxeo.importer.stream.consumer

Modifier and Type	Class	Description
class	DocumentConsumerPolicyBuilder

Uses of ConsumerPolicyBuilder in org.nuxeo.lib.stream.pattern.consumer

Methods in org.nuxeo.lib.stream.pattern.consumer that return ConsumerPolicyBuilder

Modifier and Type	Method	Description
ConsumerPolicyBuilder	ConsumerPolicyBuilder.batchPolicy(BatchPolicy policy)
static ConsumerPolicyBuilder	ConsumerPolicy.builder()
ConsumerPolicyBuilder	ConsumerPolicyBuilder.continueOnFailure(boolean value)	Continue on next message even if the retry policy has failed.
ConsumerPolicyBuilder	ConsumerPolicyBuilder.maxThreads(short maxThreads)	Maximum consumer threads to use.
ConsumerPolicyBuilder	ConsumerPolicyBuilder.name(String name)	Consumer group name.
ConsumerPolicyBuilder	ConsumerPolicyBuilder.retryPolicy(net.jodah.failsafe.RetryPolicy policy)
ConsumerPolicyBuilder	ConsumerPolicyBuilder.salted()	Consumer will wait some random time before start, to prevent wave of concurrency in batch processing.
ConsumerPolicyBuilder	ConsumerPolicyBuilder.startOffset(ConsumerPolicy.StartOffset startOffset)	Where to read the first message.
ConsumerPolicyBuilder	ConsumerPolicyBuilder.waitMessageForEver()	Consumer will wait for ever message.
ConsumerPolicyBuilder	ConsumerPolicyBuilder.waitMessageTimeout(Duration duration)	Consumer will stop if there is no more message after this timeout.

Constructors in org.nuxeo.lib.stream.pattern.consumer with parameters of type ConsumerPolicyBuilder

Constructor	Description
ConsumerPolicy(ConsumerPolicyBuilder builder)