Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.consumer |
Modifier and Type | Method and Description |
---|---|
ConsumerPolicy.Builder |
ConsumerPolicy.Builder.batchPolicy(BatchPolicy policy) |
static ConsumerPolicy.Builder |
ConsumerPolicy.builder() |
ConsumerPolicy.Builder |
ConsumerPolicy.Builder.continueOnFailure(boolean value)
Continue on next message even if the retry policy has failed.
|
ConsumerPolicy.Builder |
ConsumerPolicy.Builder.retryPolicy(net.jodah.failsafe.RetryPolicy policy) |
ConsumerPolicy.Builder |
ConsumerPolicy.Builder.salted()
Consumer will wait some random time before start, to prevent wave of concurency in batch processing.
|
ConsumerPolicy.Builder |
ConsumerPolicy.Builder.startOffset(ConsumerPolicy.StartOffset startOffset)
Where to read the first message.
|
ConsumerPolicy.Builder |
ConsumerPolicy.Builder.waitMessageForEver()
Consumer will wait for ever message.
|
ConsumerPolicy.Builder |
ConsumerPolicy.Builder.waitMessageTimeout(Duration duration)
Consumer will stop if there is no more message after this timeout.
|
Constructor and Description |
---|
ConsumerPolicy(ConsumerPolicy.Builder builder) |
Copyright © 2017 Nuxeo. All rights reserved.