K
- the key type.V
- the value type.T
- the delegate type.public abstract class AbstractRetryingMessageListenerAdapter<K,V,T> extends AbstractDelegatingMessageListenerAdapter<T>
ConsumerSeekAware.ConsumerSeekCallback
delegate, 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, registerSeekCallback
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
unregisterSeekCallback
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.