Package | Description |
---|---|
org.nuxeo.importer.stream.consumer | |
org.nuxeo.lib.stream.pattern.consumer |
Modifier and Type | Class and Description |
---|---|
class |
DocumentConsumerPolicyBuilder |
Modifier and Type | Method and 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.
|
Constructor and Description |
---|
ConsumerPolicy(ConsumerPolicyBuilder builder) |
Copyright © 2018 Nuxeo. All rights reserved.