K - the key type.V - the value type.T - the delegate type.public abstract class AbstractRetryingMessageListenerAdapter<K,V,T> extends AbstractMessageListenerAdapter<K,V,T>
ConsumerSeekAware.ConsumerSeekCallback| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
CONTEXT_ACKNOWLEDGMENT
RetryContext attribute key for an acknowledgment
if the listener is capable of acknowledging. |
static java.lang.String |
CONTEXT_RECORD
RetryContext attribute key for the record. |
delegate, logger| Constructor and Description |
|---|
AbstractRetryingMessageListenerAdapter(T delegate,
org.springframework.retry.support.RetryTemplate retryTemplate)
Construct an instance with the supplied retry template.
|
AbstractRetryingMessageListenerAdapter(T delegate,
org.springframework.retry.support.RetryTemplate retryTemplate,
org.springframework.retry.RecoveryCallback<? extends java.lang.Object> recoveryCallback)
Construct an instance with the supplied template and callback.
|
| Modifier and Type | Method and Description |
|---|---|
org.springframework.retry.RecoveryCallback<? extends java.lang.Object> |
getRecoveryCallback() |
org.springframework.retry.support.RetryTemplate |
getRetryTemplate() |
onIdleContainer, onPartitionsAssigned, registerSeekCallbackpublic static final java.lang.String CONTEXT_ACKNOWLEDGMENT
RetryContext attribute key for an acknowledgment
if the listener is capable of acknowledging.public static final java.lang.String CONTEXT_RECORD
RetryContext attribute key for the record.public AbstractRetryingMessageListenerAdapter(T delegate, org.springframework.retry.support.RetryTemplate retryTemplate)
delegate - the delegate listener.retryTemplate - the template.public AbstractRetryingMessageListenerAdapter(T delegate, org.springframework.retry.support.RetryTemplate retryTemplate, org.springframework.retry.RecoveryCallback<? extends java.lang.Object> recoveryCallback)
delegate - the delegate listener.retryTemplate - the template.recoveryCallback - the recovery callback; if null, the exception will be
thrown to the container after retries are exhausted.