public class ConsumerPolicy extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ConsumerPolicy.Builder |
static class |
ConsumerPolicy.StartOffset |
Modifier and Type | Field and Description |
---|---|
static ConsumerPolicy |
BOUNDED
Consumer policy that stop on starvation and failure.
|
static net.jodah.failsafe.RetryPolicy |
NO_RETRY |
static ConsumerPolicy |
UNBOUNDED
Consumer policy that wait for ever for new message and skip failure.
|
Constructor and Description |
---|
ConsumerPolicy(ConsumerPolicy.Builder builder) |
Modifier and Type | Method and Description |
---|---|
static ConsumerPolicy.Builder |
builder() |
boolean |
continueOnFailure() |
BatchPolicy |
getBatchPolicy() |
net.jodah.failsafe.RetryPolicy |
getRetryPolicy() |
ConsumerPolicy.StartOffset |
getStartOffset() |
Duration |
getWaitMessageTimeout() |
boolean |
isSalted() |
public static final net.jodah.failsafe.RetryPolicy NO_RETRY
public static final ConsumerPolicy BOUNDED
public static final ConsumerPolicy UNBOUNDED
public ConsumerPolicy(ConsumerPolicy.Builder builder)
public BatchPolicy getBatchPolicy()
public net.jodah.failsafe.RetryPolicy getRetryPolicy()
public boolean continueOnFailure()
public Duration getWaitMessageTimeout()
public ConsumerPolicy.StartOffset getStartOffset()
public boolean isSalted()
public static ConsumerPolicy.Builder builder()
Copyright © 2017 Nuxeo. All rights reserved.