public static enum AbstractMessageListenerContainer.AckMode extends java.lang.Enum<AbstractMessageListenerContainer.AckMode>
| Enum Constant and Description |
|---|
BATCH
Call
Consumer.commitAsync() after the results of each poll have been
passed to the listener. |
COUNT
Call
Consumer.commitAsync() for pending updates after
ackCount has been
exceeded. |
COUNT_TIME
|
MANUAL
Same as
COUNT_TIME except for pending manual acks. |
MANUAL_IMMEDIATE
Call
Consumer.commitAsync() immediately for pending acks. |
RECORD
Call
Consumer.commitAsync() after each record is passed to the listener. |
TIME
Call
Consumer.commitAsync() for pending updates after
ackTime has elapsed. |
| Modifier and Type | Method and Description |
|---|---|
static AbstractMessageListenerContainer.AckMode |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static AbstractMessageListenerContainer.AckMode[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final AbstractMessageListenerContainer.AckMode RECORD
Consumer.commitAsync() after each record is passed to the listener.public static final AbstractMessageListenerContainer.AckMode BATCH
Consumer.commitAsync() after the results of each poll have been
passed to the listener.public static final AbstractMessageListenerContainer.AckMode TIME
Consumer.commitAsync() for pending updates after
ackTime has elapsed.public static final AbstractMessageListenerContainer.AckMode COUNT
Consumer.commitAsync() for pending updates after
ackCount has been
exceeded.public static final AbstractMessageListenerContainer.AckMode COUNT_TIME
public static final AbstractMessageListenerContainer.AckMode MANUAL
COUNT_TIME except for pending manual acks.public static final AbstractMessageListenerContainer.AckMode MANUAL_IMMEDIATE
Consumer.commitAsync() immediately for pending acks.public static AbstractMessageListenerContainer.AckMode[] values()
for (AbstractMessageListenerContainer.AckMode c : AbstractMessageListenerContainer.AckMode.values()) System.out.println(c);
public static AbstractMessageListenerContainer.AckMode valueOf(java.lang.String name)
name - the name of the enum constant to be returned.java.lang.IllegalArgumentException - if this enum type has no constant with the specified namejava.lang.NullPointerException - if the argument is null