K - the key type.V - the value type.T - the delegate type.public abstract class AbstractRetryingMessageListenerAdapter<K,V,T> extends AbstractDelegatingMessageListenerAdapter<T>
ConsumerSeekAware.ConsumerSeekCallbackdelegate, delegateType, 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() |
getDelegate, onIdleContainer, onPartitionsAssigned, onPartitionsRevoked, registerSeekCallbackclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitunregisterSeekCallbackpublic 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.