Uses of Class
org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicyBuilder
Packages that use ConsumerPolicyBuilder
-
Uses of ConsumerPolicyBuilder in org.nuxeo.importer.stream.consumer
Subclasses of ConsumerPolicyBuilder in org.nuxeo.importer.stream.consumer -
Uses of ConsumerPolicyBuilder in org.nuxeo.lib.stream.pattern.consumer
Methods in org.nuxeo.lib.stream.pattern.consumer that return ConsumerPolicyBuilderModifier and TypeMethodDescriptionConsumerPolicyBuilder.batchPolicy
(BatchPolicy policy) static ConsumerPolicyBuilder
ConsumerPolicy.builder()
ConsumerPolicyBuilder.continueOnFailure
(boolean value) Continue on next message even if the retry policy has failed.ConsumerPolicyBuilder.maxThreads
(short maxThreads) Maximum consumer threads to use.Consumer group name.ConsumerPolicyBuilder.retryPolicy
(net.jodah.failsafe.RetryPolicy<Object> policy) ConsumerPolicyBuilder.salted()
Consumer will wait some random time before start, to prevent wave of concurrency in batch processing.ConsumerPolicyBuilder.startOffset
(ConsumerPolicy.StartOffset startOffset) Where to read the first message.ConsumerPolicyBuilder.waitMessageForEver()
Consumer will wait for ever message.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