Uses of Class
org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicyBuilder
-
Uses of ConsumerPolicyBuilder in org.nuxeo.importer.stream.consumer
-
Uses of ConsumerPolicyBuilder in org.nuxeo.lib.stream.pattern.consumer
Modifier 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.